public abstract class AvroProducer
extends org.apache.camel.impl.DefaultAsyncProducer
implements org.apache.camel.ServicePoolAware
Constructor and Description |
---|
AvroProducer(org.apache.camel.Endpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
abstract org.apache.avro.ipc.Transceiver |
createTransceiver() |
protected void |
doStart() |
protected void |
doStop() |
AvroEndpoint |
getEndpoint() |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
Object[] |
wrapObjectToArray(Object object) |
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 abstract org.apache.avro.ipc.Transceiver createTransceiver() throws Exception
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.impl.DefaultProducer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultProducer
Exception
public AvroEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
Apache Camel