Uses of Interface
org.apache.camel.processor.ProcessorExchangePair

Packages that use ProcessorExchangePair

org.apache.camel.processor

A collection of Processor implementations which are used to implement the Enterprise Integration Patterns

Uses of ProcessorExchangePair in org.apache.camel.processor

Methods in org.apache.camel.processor that return ProcessorExchangePair

protected ProcessorExchangePair	RecipientListProcessor.createProcessorExchangePair(int index, Endpoint endpoint, Producer producer, Exchange exchange) This logic is similar to MulticastProcessor but we have to return a RecipientProcessorExchangePair instead
protected ProcessorExchangePair	MulticastProcessor.createProcessorExchangePair(int index, Processor processor, Exchange exchange, RouteContext routeContext) Creates the ProcessorExchangePair which holds the processor and exchange to be send out.

Methods in org.apache.camel.processor that return types with arguments of type ProcessorExchangePair

protected Iterable<ProcessorExchangePair>	Splitter.createProcessorExchangePairs(Exchange exchange)
protected Iterable<ProcessorExchangePair>	RecipientListProcessor.createProcessorExchangePairs(Exchange exchange)
protected Iterable<ProcessorExchangePair>	MulticastProcessor.createProcessorExchangePairs(Exchange exchange)

Method parameters in org.apache.camel.processor with type arguments of type ProcessorExchangePair

protected void	MulticastProcessor.doDone(Exchange original, Exchange subExchange, Iterable<ProcessorExchangePair> pairs, AsyncCallback callback, boolean doneSync, boolean forceExhaust) Common work which must be done when we are done multicasting.
protected void	MulticastProcessor.doProcessParallel(Exchange original, AtomicExchange result, Iterable<ProcessorExchangePair> pairs, boolean streaming, AsyncCallback callback)
protected boolean	MulticastProcessor.doProcessSequential(Exchange original, AtomicExchange result, Iterable<ProcessorExchangePair> pairs, AsyncCallback callback)
protected void	Splitter.updateNewExchange(Exchange exchange, int index, Iterable<ProcessorExchangePair> allPairs, Iterator<ProcessorExchangePair> it)
protected void	Splitter.updateNewExchange(Exchange exchange, int index, Iterable<ProcessorExchangePair> allPairs, Iterator<ProcessorExchangePair> it)
protected void	MulticastProcessor.updateNewExchange(Exchange exchange, int index, Iterable<ProcessorExchangePair> allPairs, Iterator<ProcessorExchangePair> it)
protected void	MulticastProcessor.updateNewExchange(Exchange exchange, int index, Iterable<ProcessorExchangePair> allPairs, Iterator<ProcessorExchangePair> it)