@ManagedResource(description="JCache based message id repository") public class JCacheIdempotentRepository extends org.apache.camel.support.ServiceSupport implements org.apache.camel.spi.IdempotentRepository<Object>
Constructor and Description |
---|
JCacheIdempotentRepository() |
Modifier and Type | Method and Description |
---|---|
boolean |
add(Object key) |
void |
clear() |
boolean |
confirm(Object key) |
boolean |
contains(Object key) |
protected void |
doStart() |
protected void |
doStop() |
javax.cache.Cache<Object,Boolean> |
getCache() |
String |
getCacheName() |
org.apache.camel.CamelContext |
getCamelContext() |
ClassLoader |
getClassLoader() |
JCacheConfiguration |
getConfiguration() |
boolean |
remove(Object key) |
void |
setCache(javax.cache.Cache<Object,Boolean> cache) |
void |
setCacheName(String cacheName) |
void |
setCamelContext(org.apache.camel.CamelContext camelContext) |
void |
setClassLoader(ClassLoader classLoader) |
void |
setConfiguration(JCacheConfiguration configuration) |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public JCacheConfiguration getConfiguration()
public void setConfiguration(JCacheConfiguration configuration)
public ClassLoader getClassLoader()
public void setClassLoader(ClassLoader classLoader)
public org.apache.camel.CamelContext getCamelContext()
public void setCamelContext(org.apache.camel.CamelContext camelContext)
@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>
public void setCacheName(String cacheName)
@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.ServiceSupport
Exception
Apache Camel