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:

IsSingleton, Processor, Producer, Service, ShutdownableService, StatefulService, SuspendableService

public class KratiProducer
extends DefaultProducer

The Krati producer.

Field Summary

Fields

Modifier and Type	Field and Description
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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
Object	getKey(Exchange exchange) Retrieves the key from the URI or from the exchange headers.
String	getOperation(Exchange exchange) Retrieves the operation from the URI or from the exchange headers.
Object	getValue(Exchange exchange) Retrieves the value from the URI or from the exchange headers/body.
void	process(Exchange exchange) Processes the message 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 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(Exchange exchange)
             throws Exception

Description copied from interface: Processor

Processes the message exchange

Parameters:

exchange - the message exchange

Throws:

Exception - if an internal processing error has occurred.

getOperation

public String getOperation(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(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(Exchange exchange)

Retrieves the value from the URI or from the exchange headers/body. The header/body will take precedence over the URI.