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.

Field Summary

protected krati.store.DataStore<Object,Object>	dataStore
protected KratiEndpoint	endpoint

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

KratiProducer(KratiEndpoint endpoint, krati.store.DataStore<Object,Object> dataStore)

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, 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

Field Detail

endpoint

protected final KratiEndpoint endpoint

dataStore

protected final krati.store.DataStore<Object,Object> dataStore

Constructor Detail

KratiProducer

public KratiProducer(KratiEndpoint endpoint,
                     krati.store.DataStore<Object,Object> dataStore)

Method Detail

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.