Package org.apache.camel.component.seda
Class SedaProducer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultProducer
-
- org.apache.camel.support.DefaultAsyncProducer
-
- org.apache.camel.component.seda.SedaProducer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.AsyncProcessor
,org.apache.camel.AsyncProducer
,org.apache.camel.EndpointAware
,org.apache.camel.IsSingleton
,org.apache.camel.Processor
,org.apache.camel.Producer
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class SedaProducer extends org.apache.camel.support.DefaultAsyncProducer
-
-
Constructor Summary
Constructors Constructor Description SedaProducer(SedaEndpoint endpoint, org.apache.camel.WaitForTaskToComplete waitForTaskToComplete, long timeout, boolean blockWhenFull, boolean discardWhenFull, long offerTimeout)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
addToQueue(org.apache.camel.Exchange exchange, boolean copy)
Strategy method for adding the exchange to the queue.protected void
doStart()
protected void
doStop()
protected org.apache.camel.Exchange
prepareCopy(org.apache.camel.Exchange exchange, boolean handover)
boolean
process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
-
Methods inherited from class org.apache.camel.support.DefaultProducer
createExchange, getEndpoint, isSingleton, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
SedaProducer
public SedaProducer(SedaEndpoint endpoint, org.apache.camel.WaitForTaskToComplete waitForTaskToComplete, long timeout, boolean blockWhenFull, boolean discardWhenFull, long offerTimeout)
-
-
Method Detail
-
process
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
-
prepareCopy
protected org.apache.camel.Exchange prepareCopy(org.apache.camel.Exchange exchange, boolean handover)
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.DefaultProducer
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.DefaultProducer
- Throws:
Exception
-
addToQueue
protected void addToQueue(org.apache.camel.Exchange exchange, boolean copy) throws SedaConsumerNotAvailableException
Strategy method for adding the exchange to the queue.Will perform a blocking "put" if blockWhenFull is true, otherwise it will simply add which will throw exception if the queue is full
- Parameters:
exchange
- the exchange to add to the queuecopy
- whether to create a copy of the exchange to use for adding to the queue- Throws:
SedaConsumerNotAvailableException
-
-