org.apache.camel.component.krati
Class KratiEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.impl.ScheduledPollEndpoint
org.apache.camel.component.krati.KratiEndpoint
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class KratiEndpoint
- extends org.apache.camel.impl.ScheduledPollEndpoint
Represents a Krati endpoint.
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, 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, setProperties, setSynchronous, 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, suspend |
Methods inherited from interface org.apache.camel.Service |
start |
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
maxMessagesPerPoll
protected int maxMessagesPerPoll
KratiEndpoint
public KratiEndpoint(String uri,
KratiComponent component)
throws URISyntaxException
- Throws:
URISyntaxException
stop
public void stop()
throws Exception
- Specified by:
stop
in interface org.apache.camel.Service
- Overrides:
stop
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
isSingleton
public boolean isSingleton()
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()
getMaxMessagesPerPoll
public int getMaxMessagesPerPoll()
setMaxMessagesPerPoll
public void setMaxMessagesPerPoll(int maxMessagesPerPoll)
Apache Camel