|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.camel.support.ServiceSupport org.apache.camel.impl.DefaultProducer org.apache.camel.impl.DefaultAsyncProducer org.apache.camel.component.disruptor.DisruptorProducer
public class DisruptorProducer
A Producer for the Disruptor component.
Field Summary |
---|
Fields inherited from class org.apache.camel.impl.DefaultProducer |
---|
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
DisruptorProducer(DisruptorEndpoint endpoint,
org.apache.camel.WaitForTaskToComplete waitForTaskToComplete,
long timeout,
boolean blockWhenFull)
|
Method Summary | |
---|---|
protected void |
doStart()
|
protected void |
doStop()
|
DisruptorEndpoint |
getEndpoint()
|
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback)
|
Methods inherited from class org.apache.camel.impl.DefaultAsyncProducer |
---|
process |
Methods inherited from class org.apache.camel.impl.DefaultProducer |
---|
createExchange, createExchange, createExchange, isSingleton, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Constructor Detail |
---|
public DisruptorProducer(DisruptorEndpoint endpoint, org.apache.camel.WaitForTaskToComplete waitForTaskToComplete, long timeout, boolean blockWhenFull)
Method Detail |
---|
public DisruptorEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.Producer
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)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |