public class ThriftProducer
extends org.apache.camel.impl.DefaultProducer
implements org.apache.camel.AsyncProcessor
Modifier and Type | Field and Description |
---|---|
protected ThriftConfiguration |
configuration |
protected ThriftEndpoint |
endpoint |
Constructor and Description |
---|
ThriftProducer(ThriftEndpoint endpoint,
ThriftConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
protected void |
initializeAsyncTransport() |
protected void |
initializeSslTransport() |
protected void |
initializeSyncTransport() |
void |
process(org.apache.camel.Exchange exchange) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
createExchange, createExchange, createExchange, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected final ThriftConfiguration configuration
protected final ThriftEndpoint endpoint
public ThriftProducer(ThriftEndpoint endpoint, ThriftConfiguration configuration)
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
process
in interface org.apache.camel.AsyncProcessor
public void process(org.apache.camel.Exchange exchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
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
protected void initializeSyncTransport() throws org.apache.thrift.transport.TTransportException
org.apache.thrift.transport.TTransportException
protected void initializeAsyncTransport() throws IOException, org.apache.thrift.transport.TTransportException
IOException
org.apache.thrift.transport.TTransportException
protected void initializeSslTransport() throws org.apache.thrift.transport.TTransportException
org.apache.thrift.transport.TTransportException
Apache Camel