public class DisruptorProducer
extends org.apache.camel.impl.DefaultAsyncProducer
Constructor and Description |
---|
DisruptorProducer(DisruptorEndpoint endpoint,
org.apache.camel.WaitForTaskToComplete waitForTaskToComplete,
long timeout,
boolean blockWhenFull) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
DisruptorEndpoint |
getEndpoint() |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
createExchange, createExchange, createExchange, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public DisruptorProducer(DisruptorEndpoint endpoint, org.apache.camel.WaitForTaskToComplete waitForTaskToComplete, long timeout, boolean blockWhenFull)
public DisruptorEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultProducer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultProducer
Exception
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
Apache Camel