public class MultipleConsumerSynchronizedExchange extends AbstractSynchronizedExchange
SynchronizedExchange
interface that correctly handles all completion
synchronisation courtesies for multiple consumers.synchronizations
Constructor and Description |
---|
MultipleConsumerSynchronizedExchange(org.apache.camel.Exchange exchange,
int expectedConsumers) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Exchange |
cancelAndGetOriginalExchange() |
void |
consumed(org.apache.camel.Exchange result) |
getExchange, performSynchronization
public MultipleConsumerSynchronizedExchange(org.apache.camel.Exchange exchange, int expectedConsumers)
public void consumed(org.apache.camel.Exchange result)
public org.apache.camel.Exchange cancelAndGetOriginalExchange()
cancelAndGetOriginalExchange
in interface SynchronizedExchange
cancelAndGetOriginalExchange
in class AbstractSynchronizedExchange
Apache Camel