|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultProducer
org.apache.camel.impl.DefaultAsyncProducer
org.apache.camel.component.avro.AvroProducer
public abstract class AvroProducer
Field Summary |
---|
Fields inherited from class org.apache.camel.impl.DefaultProducer |
---|
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
AvroProducer(org.apache.camel.Endpoint endpoint)
|
Method Summary | |
---|---|
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)
|
Methods inherited from class org.apache.camel.impl.DefaultAsyncProducer |
---|
process |
Methods inherited from class org.apache.camel.impl.DefaultProducer |
---|
createExchange, createExchange, createExchange, isSingleton, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Constructor Detail |
---|
public AvroProducer(org.apache.camel.Endpoint endpoint)
Method Detail |
---|
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
public Object[] wrapObjectToArray(Object object)
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.Producer
getEndpoint
in class org.apache.camel.impl.DefaultProducer
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |