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.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addEndpoint(DisruptorEndpoint disruptorEndpoint)
int
getBufferSize()
int
getEndpointCount()
String
getName()
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)
-
-
-
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
-
getName
public String getName()
-
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()
-
-