public class DisruptorReference extends Object
Modifier and Type | Method and 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) |
public boolean hasNullReference()
public void tryPublish(org.apache.camel.Exchange exchange) throws DisruptorNotStartedException, com.lmax.disruptor.InsufficientCapacityException
DisruptorNotStartedException
com.lmax.disruptor.InsufficientCapacityException
public void publish(org.apache.camel.Exchange exchange) throws DisruptorNotStartedException
DisruptorNotStartedException
public String getName()
public long getRemainingCapacity() throws DisruptorNotStartedException
DisruptorNotStartedException
public DisruptorWaitStrategy getWaitStrategy()
public int getBufferSize()
public int getPendingExchangeCount()
public void addEndpoint(DisruptorEndpoint disruptorEndpoint)
public void removeEndpoint(DisruptorEndpoint disruptorEndpoint)
public int getEndpointCount()
Apache Camel