public class BeanstalkProducer
extends org.apache.camel.impl.DefaultProducer
implements org.apache.camel.AsyncProcessor
Constructor and Description |
---|
BeanstalkProducer(BeanstalkEndpoint endpoint,
Command command) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeClient() |
protected void |
doStart() |
protected void |
doStop() |
Command |
getCommand() |
BeanstalkEndpoint |
getEndpoint() |
protected void |
initClient() |
void |
process(org.apache.camel.Exchange exchange) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
protected void |
resetClient() |
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 BeanstalkProducer(BeanstalkEndpoint endpoint, Command command) throws Exception
Exception
public Command getCommand()
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 resetClient()
protected void closeClient()
protected void initClient()
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 BeanstalkEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
Apache Camel