public abstract class AbstractAtomixClientProducer<E extends AbstractAtomixClientEndpoint,R extends io.atomix.resource.Resource>
extends org.apache.camel.impl.DefaultProducer
implements org.apache.camel.AsyncProcessor
Modifier | Constructor and Description |
---|---|
protected |
AbstractAtomixClientProducer(E endpoint) |
Modifier and Type | Method and Description |
---|---|
protected abstract R |
createResource(String name) |
protected void |
doStart() |
protected E |
getAtomixEndpoint() |
protected abstract String |
getProcessorKey(org.apache.camel.Message message) |
protected R |
getResource(org.apache.camel.Message message) |
protected abstract String |
getResourceName(org.apache.camel.Message message) |
void |
process(org.apache.camel.Exchange exchange) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
protected void |
processResult(org.apache.camel.Message message,
org.apache.camel.AsyncCallback callback,
Object result) |
createExchange, createExchange, createExchange, doStop, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected AbstractAtomixClientProducer(E endpoint)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultProducer
Exception
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 E getAtomixEndpoint()
protected void processResult(org.apache.camel.Message message, org.apache.camel.AsyncCallback callback, Object result)
protected R getResource(org.apache.camel.Message message)
protected abstract String getProcessorKey(org.apache.camel.Message message)
protected abstract String getResourceName(org.apache.camel.Message message)
Apache Camel