public class ActorProducer
extends org.apache.camel.impl.DefaultProducer
implements org.apache.camel.AsyncProcessor
ActorEndpoint
ActorComponent
,
ActorEndpoint
Constructor and Description |
---|
ActorProducer(ActorEndpoint endpoint,
Camel camel) |
Modifier and Type | Method and Description |
---|---|
ActorEndpoint |
endpoint() |
void |
process(org.apache.camel.Exchange exchange)
Processes the exchange.
|
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback)
Processes the message exchange.
|
void |
processExchangeAdapter(CamelExchangeAdapter exchange)
INTERNAL API
Processes the
CamelExchangeAdapter |
boolean |
processExchangeAdapter(CamelExchangeAdapter exchange,
org.apache.camel.AsyncCallback callback)
INTERNAL API
Processes the
CamelExchangeAdapter . |
createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public ActorProducer(ActorEndpoint endpoint, Camel camel)
public ActorEndpoint endpoint()
public void process(org.apache.camel.Exchange exchange)
process
in interface org.apache.camel.Processor
exchange
- the exchange to processpublic boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
process
in interface org.apache.camel.AsyncProcessor
exchange
- the message exchangecallback
- the AsyncCallback will be invoked when the processing of the exchange is completed.
If the exchange is completed synchronously, then the callback is also invoked synchronously.
The callback should therefore be careful of starting recursive loop.public void processExchangeAdapter(CamelExchangeAdapter exchange)
CamelExchangeAdapter
exchange
- the CamelExchangeAdapter
public boolean processExchangeAdapter(CamelExchangeAdapter exchange, org.apache.camel.AsyncCallback callback)
CamelExchangeAdapter
.
This method is blocking when the exchange is inOnly. The method returns true if it executed synchronously/blocking.exchange
- the CamelExchangeAdapter
callback
- the callback