public class ChronicleEngineProducer
extends org.apache.camel.impl.HeaderSelectorProducer
Constructor and Description |
---|
ChronicleEngineProducer(ChronicleEngineEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
void |
onGet(org.apache.camel.Message message) |
void |
onGetAndPut(org.apache.camel.Message message) |
void |
onGetAndRemove(org.apache.camel.Message message) |
void |
onIsEmpty(org.apache.camel.Message message) |
void |
onPublish(org.apache.camel.Message message) |
void |
onPublishAndIndex(org.apache.camel.Message message) |
void |
onPut(org.apache.camel.Message message) |
void |
onPutAll(org.apache.camel.Message message) |
void |
onPutIfAbsent(org.apache.camel.Message message) |
void |
onRemove(org.apache.camel.Message message) |
void |
onSize(org.apache.camel.Message message) |
bind, getProcessor, onMissingProcessor
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
public ChronicleEngineProducer(ChronicleEngineEndpoint endpoint)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.HeaderSelectorProducer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultProducer
Exception
public void onPublish(org.apache.camel.Message message)
public void onPublishAndIndex(org.apache.camel.Message message)
public void onPut(org.apache.camel.Message message)
public void onGetAndPut(org.apache.camel.Message message)
public void onPutAll(org.apache.camel.Message message)
public void onPutIfAbsent(org.apache.camel.Message message)
public void onGet(org.apache.camel.Message message)
public void onGetAndRemove(org.apache.camel.Message message)
public void onRemove(org.apache.camel.Message message)
public void onIsEmpty(org.apache.camel.Message message)
public void onSize(org.apache.camel.Message message)
Apache Camel