public class KratiProducer
extends org.apache.camel.impl.DefaultProducer
Modifier and Type | Field and Description |
---|---|
protected krati.store.DataStore<Object,Object> |
dataStore |
protected KratiEndpoint |
endpoint |
Constructor and Description |
---|
KratiProducer(KratiEndpoint endpoint,
krati.store.DataStore<Object,Object> dataStore) |
Modifier and Type | Method and Description |
---|---|
Object |
getKey(org.apache.camel.Exchange exchange)
Retrieves the key from the URI or from the exchange headers.
|
String |
getOperation(org.apache.camel.Exchange exchange)
Retrieves the operation from the URI or from the exchange headers.
|
Object |
getValue(org.apache.camel.Exchange exchange)
Retrieves the value from the URI or from the exchange headers/body.
|
void |
process(org.apache.camel.Exchange exchange) |
createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected final KratiEndpoint endpoint
public KratiProducer(KratiEndpoint endpoint, krati.store.DataStore<Object,Object> dataStore)
public String getOperation(org.apache.camel.Exchange exchange)
public Object getKey(org.apache.camel.Exchange exchange)
public Object getValue(org.apache.camel.Exchange exchange)
Apache Camel