Class CaffeineAggregationRepository
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.component.caffeine.processor.aggregate.CaffeineAggregationRepository
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.AggregationRepository
,org.apache.camel.spi.RecoverableAggregationRepository
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class CaffeineAggregationRepository extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.spi.RecoverableAggregationRepository
-
-
Constructor Summary
Constructors Constructor Description CaffeineAggregationRepository()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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)
com.github.benmanes.caffeine.cache.Cache<String,org.apache.camel.support.DefaultExchangeHolder>
getCache()
org.apache.camel.CamelContext
getCamelContext()
String
getDeadLetterChannel()
String
getDeadLetterUri()
Set<String>
getKeys()
int
getMaximumRedeliveries()
long
getRecoveryInterval()
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(com.github.benmanes.caffeine.cache.Cache<String,org.apache.camel.support.DefaultExchangeHolder> cache)
void
setCamelContext(org.apache.camel.CamelContext camelContext)
void
setDeadLetterChannel(String deadLetterChannel)
void
setDeadLetterUri(String deadLetterUri)
void
setMaximumRedeliveries(int maximumRedeliveries)
void
setRecoveryInterval(long recoveryInterval)
void
setRecoveryInterval(long interval, TimeUnit timeUnit)
void
setUseRecovery(boolean useRecovery)
static org.apache.camel.Exchange
unmarshallExchange(org.apache.camel.CamelContext camelContext, org.apache.camel.support.DefaultExchangeHolder holder)
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Method Detail
-
getCamelContext
public org.apache.camel.CamelContext getCamelContext()
-
setCamelContext
public void setCamelContext(org.apache.camel.CamelContext camelContext)
-
getCache
public com.github.benmanes.caffeine.cache.Cache<String,org.apache.camel.support.DefaultExchangeHolder> getCache()
-
setCache
public void setCache(com.github.benmanes.caffeine.cache.Cache<String,org.apache.camel.support.DefaultExchangeHolder> cache)
-
isAllowSerializedHeaders
public boolean isAllowSerializedHeaders()
-
setAllowSerializedHeaders
public void setAllowSerializedHeaders(boolean allowSerializedHeaders)
-
setDeadLetterUri
public void setDeadLetterUri(String deadLetterUri)
- Specified by:
setDeadLetterUri
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
getDeadLetterUri
public String getDeadLetterUri()
- Specified by:
getDeadLetterUri
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
isUseRecovery
public boolean isUseRecovery()
- Specified by:
isUseRecovery
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setUseRecovery
public void setUseRecovery(boolean useRecovery)
- Specified by:
setUseRecovery
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
getDeadLetterChannel
public String getDeadLetterChannel()
-
setDeadLetterChannel
public void setDeadLetterChannel(String deadLetterChannel)
-
getRecoveryInterval
public long getRecoveryInterval()
-
getRecoveryIntervalInMillis
public long getRecoveryIntervalInMillis()
- Specified by:
getRecoveryIntervalInMillis
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setRecoveryInterval
public void setRecoveryInterval(long recoveryInterval)
- Specified by:
setRecoveryInterval
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setRecoveryInterval
public void setRecoveryInterval(long interval, TimeUnit timeUnit)
- Specified by:
setRecoveryInterval
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
getMaximumRedeliveries
public int getMaximumRedeliveries()
- Specified by:
getMaximumRedeliveries
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setMaximumRedeliveries
public void setMaximumRedeliveries(int maximumRedeliveries)
- Specified by:
setMaximumRedeliveries
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
add
public org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
- Specified by:
add
in interfaceorg.apache.camel.spi.AggregationRepository
-
get
public org.apache.camel.Exchange get(org.apache.camel.CamelContext camelContext, String key)
- Specified by:
get
in interfaceorg.apache.camel.spi.AggregationRepository
-
remove
public void remove(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
- Specified by:
remove
in interfaceorg.apache.camel.spi.AggregationRepository
-
confirm
public void confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
- Specified by:
confirm
in interfaceorg.apache.camel.spi.AggregationRepository
-
getKeys
public Set<String> getKeys()
- Specified by:
getKeys
in interfaceorg.apache.camel.spi.AggregationRepository
-
scan
public Set<String> scan(org.apache.camel.CamelContext camelContext)
- Specified by:
scan
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
recover
public org.apache.camel.Exchange recover(org.apache.camel.CamelContext camelContext, String exchangeId)
- Specified by:
recover
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
unmarshallExchange
public static org.apache.camel.Exchange unmarshallExchange(org.apache.camel.CamelContext camelContext, org.apache.camel.support.DefaultExchangeHolder holder)
-
-