public class KratiIdempotentRepository extends org.apache.camel.support.ServiceSupport implements org.apache.camel.spi.IdempotentRepository<String>
Constructor and Description |
---|
KratiIdempotentRepository(String repositoryPath) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(String s) |
void |
clear() |
boolean |
confirm(String s) |
boolean |
contains(String s) |
protected void |
doStart() |
protected void |
doStop() |
krati.store.DataSet<byte[]> |
getDataSet() |
int |
getInitialCapacity() |
String |
getRepositoryPath() |
krati.core.segment.SegmentFactory |
getSegmentFactory() |
krati.io.Serializer<String> |
getSerializer() |
boolean |
remove(String s) |
void |
setDataSet(krati.store.DataSet<byte[]> dataSet) |
void |
setInitialCapacity(int initialCapacity) |
void |
setRepositoryPath(String repositoryPath) |
void |
setSegmentFactory(krati.core.segment.SegmentFactory segmentFactory) |
void |
setSerializer(krati.io.Serializer<String> serializer) |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public KratiIdempotentRepository(String repositoryPath)
@ManagedOperation(description="Adds the key to the store") public boolean add(String s)
add
in interface org.apache.camel.spi.IdempotentRepository<String>
@ManagedOperation(description="Does the store contain the given key") public boolean contains(String s)
contains
in interface org.apache.camel.spi.IdempotentRepository<String>
@ManagedOperation(description="Removes the given key from the store") public boolean remove(String s)
remove
in interface org.apache.camel.spi.IdempotentRepository<String>
public boolean confirm(String s)
confirm
in interface org.apache.camel.spi.IdempotentRepository<String>
public void clear()
clear
in interface org.apache.camel.spi.IdempotentRepository<String>
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.ServiceSupport
Exception
public String getRepositoryPath()
public void setRepositoryPath(String repositoryPath)
public krati.store.DataSet<byte[]> getDataSet()
public void setDataSet(krati.store.DataSet<byte[]> dataSet)
public int getInitialCapacity()
public void setInitialCapacity(int initialCapacity)
public krati.io.Serializer<String> getSerializer()
public void setSerializer(krati.io.Serializer<String> serializer)
public krati.core.segment.SegmentFactory getSegmentFactory()
public void setSegmentFactory(krati.core.segment.SegmentFactory segmentFactory)
Apache Camel