org.apache.camel.component.disruptor
Class DisruptorReference

java.lang.Object
  extended by org.apache.camel.component.disruptor.DisruptorReference

public class DisruptorReference
extends Object

Holder for Disruptor references.

This is used to keep track of the usages of the Disruptors, so we know when a Disruptor is no longer in use, and can safely be discarded.


Method Summary
 void addEndpoint(DisruptorEndpoint disruptorEndpoint)
           
 int getBufferSize()
           
 int getEndpointCount()
           
 int getPendingExchangeCount()
           
 long getRemainingCapacity()
           
 DisruptorWaitStrategy getWaitStrategy()
           
 boolean hasNullReference()
           
 void publish(org.apache.camel.Exchange exchange)
           
 void reconfigure()
           
 void removeEndpoint(DisruptorEndpoint disruptorEndpoint)
           
 String toString()
           
 void tryPublish(org.apache.camel.Exchange exchange)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Method Detail

hasNullReference

public boolean hasNullReference()

tryPublish

public void tryPublish(org.apache.camel.Exchange exchange)
                throws DisruptorNotStartedException,
                       com.lmax.disruptor.InsufficientCapacityException
Throws:
DisruptorNotStartedException
com.lmax.disruptor.InsufficientCapacityException

publish

public void publish(org.apache.camel.Exchange exchange)
             throws DisruptorNotStartedException
Throws:
DisruptorNotStartedException

reconfigure

public void reconfigure()
                 throws Exception
Throws:
Exception

getRemainingCapacity

public long getRemainingCapacity()
                          throws DisruptorNotStartedException
Throws:
DisruptorNotStartedException

getWaitStrategy

public DisruptorWaitStrategy getWaitStrategy()

getBufferSize

public int getBufferSize()

getPendingExchangeCount

public int getPendingExchangeCount()

addEndpoint

public void addEndpoint(DisruptorEndpoint disruptorEndpoint)

removeEndpoint

public void removeEndpoint(DisruptorEndpoint disruptorEndpoint)

getEndpointCount

public int getEndpointCount()

toString

public String toString()
Overrides:
toString in class Object


Apache Camel