public class InfinispanLocalAggregationRepository
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.RecoverableAggregationRepository
Constructor and Description |
---|
InfinispanLocalAggregationRepository()
Creates new
InfinispanLocalAggregationRepository that defaults to non-optimistic locking
with recoverable behavior and a local Infinispan cache. |
InfinispanLocalAggregationRepository(String cacheName)
Creates new
InfinispanLocalAggregationRepository that defaults to non-optimistic locking
with recoverable behavior and a local Infinispan cache. |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Exchange |
add(org.apache.camel.CamelContext camelContext,
String key,
org.apache.camel.Exchange exchange) |
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) |
org.infinispan.commons.api.BasicCache<String,org.apache.camel.impl.DefaultExchangeHolder> |
getCache() |
String |
getCacheName() |
org.infinispan.configuration.cache.Configuration |
getConfiguration() |
String |
getDeadLetterChannel() |
String |
getDeadLetterUri() |
Set<String> |
getKeys() |
org.infinispan.manager.DefaultCacheManager |
getManager() |
int |
getMaximumRedeliveries() |
long |
getRecoveryIntervalInMillis() |
boolean |
isAllowSerializedHeaders() |
boolean |
isUseRecovery() |
org.apache.camel.Exchange |
recover(org.apache.camel.CamelContext camelContext,
String exchangeId) |
void |
remove(org.apache.camel.CamelContext camelContext,
String key,
org.apache.camel.Exchange exchange) |
Set<String> |
scan(org.apache.camel.CamelContext camelContext) |
void |
setAllowSerializedHeaders(boolean allowSerializedHeaders) |
void |
setCache(org.infinispan.commons.api.BasicCache<String,org.apache.camel.impl.DefaultExchangeHolder> cache) |
void |
setCacheName(String cacheName) |
void |
setConfiguration(org.infinispan.configuration.cache.Configuration configuration) |
void |
setDeadLetterChannel(String deadLetterChannel) |
void |
setDeadLetterUri(String deadLetterUri) |
void |
setManager(org.infinispan.manager.DefaultCacheManager manager) |
void |
setMaximumRedeliveries(int maximumRedeliveries) |
void |
setRecoveryInterval(long interval) |
void |
setRecoveryInterval(long interval,
TimeUnit timeUnit) |
void |
setUseRecovery(boolean useRecovery) |
protected org.apache.camel.Exchange |
unmarshallExchange(org.apache.camel.CamelContext camelContext,
org.apache.camel.impl.DefaultExchangeHolder holder) |
public InfinispanLocalAggregationRepository()
InfinispanLocalAggregationRepository
that defaults to non-optimistic locking
with recoverable behavior and a local Infinispan cache.public InfinispanLocalAggregationRepository(String cacheName)
InfinispanLocalAggregationRepository
that defaults to non-optimistic locking
with recoverable behavior and a local Infinispan cache.cacheName
- cache namepublic 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
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
public Set<String> scan(org.apache.camel.CamelContext camelContext)
scan
in interface org.apache.camel.spi.RecoverableAggregationRepository
public org.apache.camel.Exchange recover(org.apache.camel.CamelContext camelContext, String exchangeId)
recover
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setRecoveryInterval(long interval, TimeUnit timeUnit)
setRecoveryInterval
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setRecoveryInterval(long interval)
setRecoveryInterval
in interface org.apache.camel.spi.RecoverableAggregationRepository
public long getRecoveryIntervalInMillis()
getRecoveryIntervalInMillis
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setUseRecovery(boolean useRecovery)
setUseRecovery
in interface org.apache.camel.spi.RecoverableAggregationRepository
public boolean isUseRecovery()
isUseRecovery
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setDeadLetterUri(String deadLetterUri)
setDeadLetterUri
in interface org.apache.camel.spi.RecoverableAggregationRepository
public String getDeadLetterUri()
getDeadLetterUri
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setMaximumRedeliveries(int maximumRedeliveries)
setMaximumRedeliveries
in interface org.apache.camel.spi.RecoverableAggregationRepository
public int getMaximumRedeliveries()
getMaximumRedeliveries
in interface org.apache.camel.spi.RecoverableAggregationRepository
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)
public org.infinispan.manager.DefaultCacheManager getManager()
public void setManager(org.infinispan.manager.DefaultCacheManager manager)
public String getCacheName()
public void setCacheName(String cacheName)
public String getDeadLetterChannel()
public void setDeadLetterChannel(String deadLetterChannel)
public boolean isAllowSerializedHeaders()
public void setAllowSerializedHeaders(boolean allowSerializedHeaders)
public org.infinispan.commons.api.BasicCache<String,org.apache.camel.impl.DefaultExchangeHolder> getCache()
public void setCache(org.infinispan.commons.api.BasicCache<String,org.apache.camel.impl.DefaultExchangeHolder> cache)
public org.infinispan.configuration.cache.Configuration getConfiguration()
public void setConfiguration(org.infinispan.configuration.cache.Configuration configuration)
Apache Camel