org.apache.camel.component.krati
Class KratiProducer
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultProducer
org.apache.camel.component.krati.KratiProducer
- All Implemented Interfaces:
- org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class KratiProducer
- extends org.apache.camel.impl.DefaultProducer
The Krati producer.
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 |
Method Summary |
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)
|
Methods inherited from class org.apache.camel.impl.DefaultProducer |
createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
endpoint
protected final KratiEndpoint endpoint
dataStore
protected final krati.store.DataStore<Object,Object> dataStore
KratiProducer
public KratiProducer(KratiEndpoint endpoint,
krati.store.DataStore<Object,Object> dataStore)
process
public void process(org.apache.camel.Exchange exchange)
throws Exception
- Throws:
Exception
getOperation
public String getOperation(org.apache.camel.Exchange exchange)
- Retrieves the operation from the URI or from the exchange headers. The header will take precedence over the URI.
getKey
public Object getKey(org.apache.camel.Exchange exchange)
- Retrieves the key from the URI or from the exchange headers. The header will take precedence over the URI.
getValue
public Object getValue(org.apache.camel.Exchange exchange)
- Retrieves the value from the URI or from the exchange headers/body. The header/body will take precedence over the URI.
Apache CAMEL