@ManagedResource(description="Infinispan based message id repository") public class InfinispanIdempotentRepository extends org.apache.camel.support.ServiceSupport implements org.apache.camel.spi.IdempotentRepository<Object>
| Constructor and Description |
|---|
InfinispanIdempotentRepository() |
InfinispanIdempotentRepository(org.infinispan.commons.api.BasicCacheContainer cacheContainer,
String cacheName) |
InfinispanIdempotentRepository(String cacheName) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
add(Object key) |
void |
clear() |
boolean |
confirm(Object key) |
boolean |
contains(Object key) |
protected void |
doShutdown() |
protected void |
doStart() |
protected void |
doStop() |
String |
getCacheName() |
static InfinispanIdempotentRepository |
infinispanIdempotentRepository() |
static InfinispanIdempotentRepository |
infinispanIdempotentRepository(org.infinispan.commons.api.BasicCacheContainer cacheContainer,
String processorName) |
static InfinispanIdempotentRepository |
infinispanIdempotentRepository(String processorName) |
boolean |
remove(Object key) |
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic InfinispanIdempotentRepository(org.infinispan.commons.api.BasicCacheContainer cacheContainer,
String cacheName)
public InfinispanIdempotentRepository(String cacheName)
public InfinispanIdempotentRepository()
public static InfinispanIdempotentRepository infinispanIdempotentRepository(org.infinispan.commons.api.BasicCacheContainer cacheContainer, String processorName)
public static InfinispanIdempotentRepository infinispanIdempotentRepository(String processorName)
public static InfinispanIdempotentRepository infinispanIdempotentRepository()
@ManagedOperation(description="Adds the key to the store") public boolean add(Object key)
add in interface org.apache.camel.spi.IdempotentRepository<Object>@ManagedOperation(description="Does the store contain the given key") public boolean contains(Object key)
contains in interface org.apache.camel.spi.IdempotentRepository<Object>@ManagedOperation(description="Remove the key from the store") public boolean remove(Object key)
remove in interface org.apache.camel.spi.IdempotentRepository<Object>@ManagedOperation(description="Clear the store") public void clear()
clear in interface org.apache.camel.spi.IdempotentRepository<Object>@ManagedAttribute(description="The processor name") public String getCacheName()
public boolean confirm(Object key)
confirm in interface org.apache.camel.spi.IdempotentRepository<Object>protected void doStart()
throws Exception
doStart in class org.apache.camel.support.ServiceSupportExceptionprotected void doStop()
throws Exception
doStop in class org.apache.camel.support.ServiceSupportExceptionApache Camel