org.apache.camel.component.krati

Class KratiEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.apache.camel.component.krati.KratiEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, HasId, StatefulService, SuspendableService

public class KratiEndpoint
extends DefaultEndpoint

Represents a Krati endpoint.

Field Summary

Fields

Modifier and Type	Field and Description
protected static Map<String,KratiDataStoreRegistration>	dataStoreRegistry
protected krati.util.HashFunction<byte[]>	hashFunction
protected int	initialCapacity
protected String	key
protected krati.io.Serializer<Object>	keySerializer
protected String	operation
protected String	path
protected krati.core.segment.SegmentFactory	segmentFactory
protected int	segmentFileSize
protected String	value
protected krati.io.Serializer<Object>	valueSerializer

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
KratiEndpoint(String uri, KratiComponent component)

Method Summary

Methods

Modifier and Type	Method and Description
Consumer	createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
Producer	createProducer() Creates a new producer which is used send messages into the endpoint
krati.util.HashFunction<byte[]>	getHashFunction()
int	getInitialCapacity()
String	getKey()
String	getOperation()
String	getPath()
protected String	getPath(String uri) Returns the path from the URI.
krati.core.segment.SegmentFactory	getSegmentFactory()
int	getSegmentFileSize()
String	getValue()
boolean	isSingleton() Whether this class supports being singleton or not.
void	setHashFunction(krati.util.HashFunction<byte[]> hashFunction)
void	setInitialCapacity(int initialCapacity)
void	setKey(String key)
void	setOperation(String operation)
void	setSegmentFactory(krati.core.segment.SegmentFactory segmentFactory)
void	setSegmentFileSize(int segmentFileSize)
void	setValue(String value)
void	stop() Stops the service

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, 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, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start

Field Detail

dataStoreRegistry

protected static Map<String,KratiDataStoreRegistration> dataStoreRegistry

key

protected String key

value

protected String value

operation

protected String operation

initialCapacity

protected int initialCapacity

segmentFileSize

protected int segmentFileSize

keySerializer

protected krati.io.Serializer<Object> keySerializer

valueSerializer

protected krati.io.Serializer<Object> valueSerializer

segmentFactory

protected krati.core.segment.SegmentFactory segmentFactory

hashFunction

protected krati.util.HashFunction<byte[]> hashFunction

path

protected String path

Constructor Detail

KratiEndpoint

public KratiEndpoint(String uri,
             KratiComponent component)
              throws URISyntaxException

Throws:

URISyntaxException

Method Detail

stop

public void stop()
          throws Exception

Description copied from interface: Service

Stops the service

Specified by:

stop in interface Service

Overrides:

stop in class ServiceSupport

Throws:

Exception - is thrown if stopping failed

createProducer

public Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

Creates a new producer which is used send messages into the endpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown

createConsumer

public Consumer createConsumer(Processor processor)
                        throws Exception

Description copied from interface: Endpoint

Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

isSingleton

public boolean isSingleton()

Description copied from interface: IsSingleton

Whether this class supports being singleton or not.

Returns:

true to be a single shared instance, false to create new instances.

getPath

protected String getPath(String uri)
                  throws URISyntaxException

Returns the path from the URI.

Parameters:

uri -

Returns:

Throws:

URISyntaxException

getKey

public String getKey()

setKey

public void setKey(String key)

getValue

public String getValue()

setValue

public void setValue(String value)

getOperation

public String getOperation()

setOperation

public void setOperation(String operation)

getInitialCapacity

public int getInitialCapacity()

setInitialCapacity

public void setInitialCapacity(int initialCapacity)

getSegmentFileSize

public int getSegmentFileSize()

setSegmentFileSize

public void setSegmentFileSize(int segmentFileSize)

getSegmentFactory

public krati.core.segment.SegmentFactory getSegmentFactory()

setSegmentFactory

public void setSegmentFactory(krati.core.segment.SegmentFactory segmentFactory)

getHashFunction

public krati.util.HashFunction<byte[]> getHashFunction()

setHashFunction

public void setHashFunction(krati.util.HashFunction<byte[]> hashFunction)

getPath

public String getPath()