public class InfinispanRemoteAggregationRepository
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.RecoverableAggregationRepository
| Constructor and Description |
|---|
InfinispanRemoteAggregationRepository()
Creates new
InfinispanRemoteAggregationRepository that defaults to non-optimistic locking
with recoverable behavior and a local Infinispan cache. |
InfinispanRemoteAggregationRepository(String cacheName)
Creates new
InfinispanRemoteAggregationRepository 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.client.hotrod.configuration.Configuration |
getConfiguration() |
String |
getDeadLetterChannel() |
String |
getDeadLetterUri() |
Set<String> |
getKeys() |
org.infinispan.client.hotrod.RemoteCacheManager |
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.client.hotrod.configuration.Configuration configuration) |
void |
setDeadLetterChannel(String deadLetterChannel) |
void |
setDeadLetterUri(String deadLetterUri) |
void |
setManager(org.infinispan.client.hotrod.RemoteCacheManager 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 InfinispanRemoteAggregationRepository()
InfinispanRemoteAggregationRepository that defaults to non-optimistic locking
with recoverable behavior and a local Infinispan cache.public InfinispanRemoteAggregationRepository(String cacheName)
InfinispanRemoteAggregationRepository 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.AggregationRepositorypublic org.apache.camel.Exchange get(org.apache.camel.CamelContext camelContext,
String key)
get in interface org.apache.camel.spi.AggregationRepositorypublic void remove(org.apache.camel.CamelContext camelContext,
String key,
org.apache.camel.Exchange exchange)
remove in interface org.apache.camel.spi.AggregationRepositorypublic void confirm(org.apache.camel.CamelContext camelContext,
String exchangeId)
confirm in interface org.apache.camel.spi.AggregationRepositorypublic Set<String> getKeys()
getKeys in interface org.apache.camel.spi.AggregationRepositorypublic Set<String> scan(org.apache.camel.CamelContext camelContext)
scan in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic org.apache.camel.Exchange recover(org.apache.camel.CamelContext camelContext,
String exchangeId)
recover in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic void setRecoveryInterval(long interval,
TimeUnit timeUnit)
setRecoveryInterval in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic void setRecoveryInterval(long interval)
setRecoveryInterval in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic long getRecoveryIntervalInMillis()
getRecoveryIntervalInMillis in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic void setUseRecovery(boolean useRecovery)
setUseRecovery in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic boolean isUseRecovery()
isUseRecovery in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic void setDeadLetterUri(String deadLetterUri)
setDeadLetterUri in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic String getDeadLetterUri()
getDeadLetterUri in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic void setMaximumRedeliveries(int maximumRedeliveries)
setMaximumRedeliveries in interface org.apache.camel.spi.RecoverableAggregationRepositorypublic int getMaximumRedeliveries()
getMaximumRedeliveries in interface org.apache.camel.spi.RecoverableAggregationRepositoryprotected void doStart()
throws Exception
doStart in class org.apache.camel.support.ServiceSupportExceptionprotected void doStop()
throws Exception
doStop in class org.apache.camel.support.ServiceSupportExceptionprotected org.apache.camel.Exchange unmarshallExchange(org.apache.camel.CamelContext camelContext,
org.apache.camel.impl.DefaultExchangeHolder holder)
public org.infinispan.client.hotrod.RemoteCacheManager getManager()
public void setManager(org.infinispan.client.hotrod.RemoteCacheManager 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.client.hotrod.configuration.Configuration getConfiguration()
public void setConfiguration(org.infinispan.client.hotrod.configuration.Configuration configuration)
Apache Camel