org.apache.camel.component.disruptor
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 the SynchronizedExchange 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

MultipleConsumerSynchronizedExchange(org.apache.camel.Exchange exchange, int expectedConsumers)

Method Summary

org.apache.camel.Exchange	cancelAndGetOriginalExchange()
void	consumed(org.apache.camel.Exchange result)

Methods inherited from class org.apache.camel.component.disruptor.AbstractSynchronizedExchange

getExchange, performSynchronization

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultipleConsumerSynchronizedExchange

public MultipleConsumerSynchronizedExchange(org.apache.camel.Exchange exchange,
                                            int expectedConsumers)

Method Detail

consumed

public void consumed(org.apache.camel.Exchange result)

cancelAndGetOriginalExchange

public org.apache.camel.Exchange cancelAndGetOriginalExchange()

Specified by:

cancelAndGetOriginalExchange in interface SynchronizedExchange

Overrides:

cancelAndGetOriginalExchange in class AbstractSynchronizedExchange