Class MultipleConsumerSynchronizedExchange
- java.lang.Object
-
- org.apache.camel.component.disruptor.AbstractSynchronizedExchange
-
- org.apache.camel.component.disruptor.MultipleConsumerSynchronizedExchange
-
- All Implemented Interfaces:
SynchronizedExchange
public class MultipleConsumerSynchronizedExchange extends AbstractSynchronizedExchange
Implementation of theSynchronizedExchange
interface that correctly handles all completion synchronisation courtesies for multiple consumers.
-
-
Field Summary
-
Fields inherited from class org.apache.camel.component.disruptor.AbstractSynchronizedExchange
synchronizations
-
-
Constructor Summary
Constructors Constructor Description MultipleConsumerSynchronizedExchange(org.apache.camel.Exchange exchange, int expectedConsumers)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.Exchange
cancelAndGetOriginalExchange()
void
consumed(org.apache.camel.Exchange result)
-
Methods inherited from class org.apache.camel.component.disruptor.AbstractSynchronizedExchange
getExchange, performSynchronization
-
-
-
-
Method Detail
-
consumed
public void consumed(org.apache.camel.Exchange result)
-
cancelAndGetOriginalExchange
public org.apache.camel.Exchange cancelAndGetOriginalExchange()
- Specified by:
cancelAndGetOriginalExchange
in interfaceSynchronizedExchange
- Overrides:
cancelAndGetOriginalExchange
in classAbstractSynchronizedExchange
-
-