Class RedisAggregationRepository
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.component.redis.processor.aggregate.RedisAggregationRepository
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.AggregationRepository
,org.apache.camel.spi.OptimisticLockingAggregationRepository
,org.apache.camel.spi.RecoverableAggregationRepository
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class RedisAggregationRepository extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.spi.RecoverableAggregationRepository, org.apache.camel.spi.OptimisticLockingAggregationRepository
AggregationRepository
using Redis as store.
-
-
Constructor Summary
Constructors Constructor Description RedisAggregationRepository()
RedisAggregationRepository(String mapName, String endpoint)
RedisAggregationRepository(String mapName, String endpoint, boolean optimistic)
RedisAggregationRepository(String mapName, String persistenceMapName, String endpoint)
RedisAggregationRepository(String mapName, String persistenceMapName, String endpoint, boolean optimistic)
-
Method Summary
All 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)
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)
boolean
containsKey(Object key)
Checks if the key in question is in the repository.protected void
doInit()
protected void
doStart()
protected void
doStop()
org.apache.camel.Exchange
get(org.apache.camel.CamelContext camelContext, String key)
String
getDeadLetterUri()
String
getEndpoint()
Set<String>
getKeys()
String
getMapName()
int
getMaximumRedeliveries()
String
getPersistenceMapName()
String
getPersistentRepositoryName()
long
getRecoveryIntervalInMillis()
org.redisson.api.RedissonClient
getRedisson()
boolean
isAllowSerializedHeaders()
boolean
isOptimistic()
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
setDeadLetterUri(String deadLetterUri)
void
setEndpoint(String endpoint)
void
setMapName(String mapName)
void
setMaximumRedeliveries(int maximumRedeliveries)
void
setOptimistic(boolean optimistic)
void
setPersistenceMapName(String persistenceMapName)
void
setRecoveryInterval(long interval)
void
setRecoveryInterval(long interval, TimeUnit timeUnit)
void
setRedisson(org.redisson.api.RedissonClient redisson)
void
setUseRecovery(boolean useRecovery)
protected 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, 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
-
-
-
-
Constructor Detail
-
RedisAggregationRepository
public RedisAggregationRepository()
-
RedisAggregationRepository
public RedisAggregationRepository(String mapName, String persistenceMapName, String endpoint)
-
RedisAggregationRepository
public RedisAggregationRepository(String mapName, String endpoint, boolean optimistic)
-
-
Method Detail
-
add
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
- Specified by:
add
in interfaceorg.apache.camel.spi.OptimisticLockingAggregationRepository
- Throws:
org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException
-
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
-
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
-
isOptimistic
public boolean isOptimistic()
-
setOptimistic
public void setOptimistic(boolean optimistic)
-
getEndpoint
public String getEndpoint()
-
setEndpoint
public void setEndpoint(String endpoint)
-
getMapName
public String getMapName()
-
setMapName
public void setMapName(String mapName)
-
getPersistenceMapName
public String getPersistenceMapName()
-
setPersistenceMapName
public void setPersistenceMapName(String persistenceMapName)
-
getRedisson
public org.redisson.api.RedissonClient getRedisson()
-
setRedisson
public void setRedisson(org.redisson.api.RedissonClient redisson)
-
setRecoveryInterval
public void setRecoveryInterval(long interval, TimeUnit timeUnit)
- Specified by:
setRecoveryInterval
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setRecoveryInterval
public void setRecoveryInterval(long interval)
- Specified by:
setRecoveryInterval
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
getRecoveryIntervalInMillis
public long getRecoveryIntervalInMillis()
- Specified by:
getRecoveryIntervalInMillis
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setUseRecovery
public void setUseRecovery(boolean useRecovery)
- Specified by:
setUseRecovery
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
isUseRecovery
public boolean isUseRecovery()
- Specified by:
isUseRecovery
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
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
-
setMaximumRedeliveries
public void setMaximumRedeliveries(int maximumRedeliveries)
- Specified by:
setMaximumRedeliveries
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
getMaximumRedeliveries
public int getMaximumRedeliveries()
- Specified by:
getMaximumRedeliveries
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
get
public org.apache.camel.Exchange get(org.apache.camel.CamelContext camelContext, String key)
- Specified by:
get
in interfaceorg.apache.camel.spi.AggregationRepository
-
containsKey
public boolean containsKey(Object key)
Checks if the key in question is in the repository.- Parameters:
key
- Object - key in question
-
isAllowSerializedHeaders
public boolean isAllowSerializedHeaders()
-
setAllowSerializedHeaders
public void setAllowSerializedHeaders(boolean allowSerializedHeaders)
-
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
- Specified by:
remove
in interfaceorg.apache.camel.spi.OptimisticLockingAggregationRepository
-
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
-
getPersistentRepositoryName
public String getPersistentRepositoryName()
-
doInit
protected void doInit() throws Exception
- Overrides:
doInit
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
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
protected org.apache.camel.Exchange unmarshallExchange(org.apache.camel.CamelContext camelContext, org.apache.camel.support.DefaultExchangeHolder holder)
-
-