org.apache.camel.component.disruptor
Class DisruptorReference
java.lang.Object
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.
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