public class ThriftConsumer
extends org.apache.camel.impl.DefaultConsumer
Constructor and Description |
---|
ThriftConsumer(ThriftEndpoint endpoint,
org.apache.camel.Processor processor,
ThriftConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
ThriftConfiguration |
getConfiguration() |
protected void |
initializeServer() |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public ThriftConsumer(ThriftEndpoint endpoint, org.apache.camel.Processor processor, ThriftConfiguration configuration)
public ThriftConfiguration getConfiguration()
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void initializeServer() throws org.apache.thrift.transport.TTransportException, IOException
org.apache.thrift.transport.TTransportException
IOException
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
Apache Camel