public class RouteboxDirectProducer extends RouteboxServiceSupport implements org.apache.camel.Producer, org.apache.camel.AsyncProcessor
Modifier and Type | Field and Description |
---|---|
protected org.apache.camel.ProducerTemplate |
producer |
Constructor and Description |
---|
RouteboxDirectProducer(RouteboxDirectEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Exchange |
createExchange() |
org.apache.camel.Exchange |
createExchange(org.apache.camel.Exchange exchange) |
org.apache.camel.Exchange |
createExchange(org.apache.camel.ExchangePattern pattern) |
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.Endpoint |
getEndpoint() |
boolean |
isSingleton() |
void |
process(org.apache.camel.Exchange exchange) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
String |
toString() |
doStartInnerContext, doStopInnerContext, getExceptionHandler, getExecutor, getRouteboxEndpoint, isStartedInnerContext, setExceptionHandler, setExecutor, setRouteboxEndpoint, setStartedInnerContext
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public RouteboxDirectProducer(RouteboxDirectEndpoint endpoint)
public void process(org.apache.camel.Exchange exchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
process
in interface org.apache.camel.AsyncProcessor
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.ServiceSupport
Exception
public org.apache.camel.Endpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
public org.apache.camel.Exchange createExchange()
createExchange
in interface org.apache.camel.Producer
public org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern pattern)
createExchange
in interface org.apache.camel.Producer
public org.apache.camel.Exchange createExchange(org.apache.camel.Exchange exchange)
createExchange
in interface org.apache.camel.Producer
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
Apache Camel