Toggle navigation
Home
org.apache.camel.Message to org.apache.camel.Exchange
No. of Instances - 9
No. of Commits - 5
No. of Projects - {'camel'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
getIn
to
process
exchange.getOut()
to
PipelineHelper
exchange.getIn()
to
PipelineHelper
exchange.getIn()
to
PipelineHelper.createNextExchange(exchange)
exchange.getOut()
to
PipelineHelper
exchange.getIn()
to
PipelineHelper
inputMessage
to
exchange.getIn()
inputMessage.getExchange()
to
exchange
inputMessage
to
exchange.getIn()
inputMessage.getExchange()
to
exchange
inputMessage
to
exchange.getIn()
Cascading Type Change (Similar)
Message
to
Exchange
Subscriber<Message>
to
Subscriber<Exchange>
Message
to
Exchange
Subscriber<Message>
to
Subscriber<Exchange>
Update Anonymous class
{ @Override public void onCompleted(){ try { ServiceHelper.stopService(producerTemplate); } catch ( Exception e) { throw new RuntimeCamelRxException(e); } finally { producerTemplate=null; } if (!s.isUnsubscribed()) { s.onCompleted(); } } @Override public void onError( Throwable e){ if (!s.isUnsubscribed()) { s.onError(e); } } @Override public void onNext( Message item){ if (!s.isUnsubscribed()) { Exchange exchange=process(item); if (exchange.getException() != null) { s.onError(exchange.getException()); } else { if (exchange.hasOut()) { s.onNext(exchange.getOut()); } else { s.onNext(exchange.getIn()); } } } } }
to
{ @Override public void onCompleted(){ try { ServiceHelper.stopService(producerTemplate); } catch ( Exception e) { throw new RuntimeCamelRxException(e); } finally { producerTemplate=null; } if (!s.isUnsubscribed()) { s.onCompleted(); } } @Override public void onError( Throwable e){ if (!s.isUnsubscribed()) { s.onError(e); } } @Override public void onNext( Exchange item){ if (!s.isUnsubscribed()) { Exchange exchange=process(item); if (exchange.getException() != null) { s.onError(exchange.getException()); } else { s.onNext(PipelineHelper.createNextExchange(exchange)); } } } }
{ @Override public void onCompleted(){ try { ServiceHelper.stopService(producerTemplate); } catch ( Exception e) { throw new RuntimeCamelRxException(e); } finally { producerTemplate=null; } if (!s.isUnsubscribed()) { s.onCompleted(); } } @Override public void onError( Throwable e){ if (!s.isUnsubscribed()) { s.onError(e); } } @Override public void onNext( Message item){ if (!s.isUnsubscribed()) { Exchange exchange=process(item); if (exchange.getException() != null) { s.onError(exchange.getException()); } else { if (exchange.hasOut()) { s.onNext(exchange.getOut()); } else { s.onNext(exchange.getIn()); } } } } }
to
{ @Override public void onCompleted(){ try { ServiceHelper.stopService(producerTemplate); } catch ( Exception e) { throw new RuntimeCamelRxException(e); } finally { producerTemplate=null; } if (!s.isUnsubscribed()) { s.onCompleted(); } } @Override public void onError( Throwable e){ if (!s.isUnsubscribed()) { s.onError(e); } } @Override public void onNext( Exchange item){ if (!s.isUnsubscribed()) { Exchange exchange=process(item); if (exchange.getException() != null) { s.onError(exchange.getException()); } else { s.onNext(PipelineHelper.createNextExchange(exchange)); } } } }
Rename Variable
inputMessage
to
exchange
inputMessage
to
exchange
inputMessage
to
exchange
inputMessage
to
exchange
inputMessage
to
exchange
inputMessage
to
exchange
inputMessage
to
exchange
inputMessage
to
exchange
inputMessage
to
exchange