org.apache.camel.component.krati.processor.idempotent
Class KratiIdempotentRepository

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.component.krati.processor.idempotent.KratiIdempotentRepository
All Implemented Interfaces:
org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.IdempotentRepository<String>, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class KratiIdempotentRepository
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.IdempotentRepository<String>


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
KratiIdempotentRepository(String repositoryPath)
           
 
Method Summary
 boolean add(String s)
           
 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)
           
 
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, toString, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

KratiIdempotentRepository

public KratiIdempotentRepository(String repositoryPath)
Method Detail

add

@ManagedOperation(description="Adds the key to the store")
public boolean add(String s)
Specified by:
add in interface org.apache.camel.spi.IdempotentRepository<String>

contains

@ManagedOperation(description="Does the store contain the given key")
public boolean contains(String s)
Specified by:
contains in interface org.apache.camel.spi.IdempotentRepository<String>

remove

@ManagedOperation(description="Removes the given key from the store")
public boolean remove(String s)
Specified by:
remove in interface org.apache.camel.spi.IdempotentRepository<String>

confirm

public boolean confirm(String s)
Specified by:
confirm in interface org.apache.camel.spi.IdempotentRepository<String>

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class org.apache.camel.support.ServiceSupport
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Specified by:
doStop in class org.apache.camel.support.ServiceSupport
Throws:
Exception

getRepositoryPath

public String getRepositoryPath()

setRepositoryPath

public void setRepositoryPath(String repositoryPath)

getDataSet

public krati.store.DataSet<byte[]> getDataSet()

setDataSet

public void setDataSet(krati.store.DataSet<byte[]> dataSet)

getInitialCapacity

public int getInitialCapacity()

setInitialCapacity

public void setInitialCapacity(int initialCapacity)

getSerializer

public krati.io.Serializer<String> getSerializer()

setSerializer

public void setSerializer(krati.io.Serializer<String> serializer)

getSegmentFactory

public krati.core.segment.SegmentFactory getSegmentFactory()

setSegmentFactory

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


Apache Camel