public class JCacheAggregationRepository
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.OptimisticLockingAggregationRepository
Constructor and Description |
---|
JCacheAggregationRepository() |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Exchange |
add(org.apache.camel.CamelContext camelContext,
String key,
org.apache.camel.Exchange exchange) |
org.apache.camel.Exchange |
add(org.apache.camel.CamelContext camelContext,
String key,
org.apache.camel.Exchange oldExchange,
org.apache.camel.Exchange newExchange) |
void |
confirm(org.apache.camel.CamelContext camelContext,
String exchangeId) |
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.Exchange |
get(org.apache.camel.CamelContext camelContext,
String key) |
javax.cache.Cache<String,org.apache.camel.impl.DefaultExchangeHolder> |
getCache() |
String |
getCacheName() |
JCacheConfiguration |
getConfiguration() |
Set<String> |
getKeys() |
boolean |
isAllowSerializedHeaders() |
boolean |
isOptimistic() |
void |
remove(org.apache.camel.CamelContext camelContext,
String key,
org.apache.camel.Exchange exchange) |
void |
setAllowSerializedHeaders(boolean allowSerializedHeaders) |
void |
setCache(javax.cache.Cache<String,org.apache.camel.impl.DefaultExchangeHolder> cache) |
void |
setCacheName(String cacheName) |
void |
setConfiguration(JCacheConfiguration configuration) |
void |
setOptimistic(boolean optimistic) |
protected org.apache.camel.Exchange |
unmarshallExchange(org.apache.camel.CamelContext camelContext,
org.apache.camel.impl.DefaultExchangeHolder holder) |
public JCacheConfiguration getConfiguration()
public void setConfiguration(JCacheConfiguration configuration)
public String getCacheName()
public void setCacheName(String cacheName)
public javax.cache.Cache<String,org.apache.camel.impl.DefaultExchangeHolder> getCache()
public void setCache(javax.cache.Cache<String,org.apache.camel.impl.DefaultExchangeHolder> cache)
public boolean isOptimistic()
public void setOptimistic(boolean optimistic)
public boolean isAllowSerializedHeaders()
public void setAllowSerializedHeaders(boolean allowSerializedHeaders)
public org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange oldExchange, org.apache.camel.Exchange newExchange) throws org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException
add
in interface org.apache.camel.spi.OptimisticLockingAggregationRepository
org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException
public org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
add
in interface org.apache.camel.spi.AggregationRepository
public org.apache.camel.Exchange get(org.apache.camel.CamelContext camelContext, String key)
get
in interface org.apache.camel.spi.AggregationRepository
public void remove(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
remove
in interface org.apache.camel.spi.AggregationRepository
remove
in interface org.apache.camel.spi.OptimisticLockingAggregationRepository
public void confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
confirm
in interface org.apache.camel.spi.AggregationRepository
public Set<String> getKeys()
getKeys
in interface org.apache.camel.spi.AggregationRepository
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
protected org.apache.camel.Exchange unmarshallExchange(org.apache.camel.CamelContext camelContext, org.apache.camel.impl.DefaultExchangeHolder holder)
Apache Camel