Class 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 Detail

      • RedisAggregationRepository

        public RedisAggregationRepository()
      • RedisAggregationRepository

        public RedisAggregationRepository​(String mapName,
                                          String endpoint)
      • RedisAggregationRepository

        public RedisAggregationRepository​(String mapName,
                                          String persistenceMapName,
                                          String endpoint)
      • RedisAggregationRepository

        public RedisAggregationRepository​(String mapName,
                                          String endpoint,
                                          boolean optimistic)
      • RedisAggregationRepository

        public RedisAggregationRepository​(String mapName,
                                          String persistenceMapName,
                                          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 interface org.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 interface org.apache.camel.spi.AggregationRepository
      • scan

        public Set<String> scan​(org.apache.camel.CamelContext camelContext)
        Specified by:
        scan in interface org.apache.camel.spi.RecoverableAggregationRepository
      • recover

        public org.apache.camel.Exchange recover​(org.apache.camel.CamelContext camelContext,
                                                 String exchangeId)
        Specified by:
        recover in interface org.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 interface org.apache.camel.spi.RecoverableAggregationRepository
      • setRecoveryInterval

        public void setRecoveryInterval​(long interval)
        Specified by:
        setRecoveryInterval in interface org.apache.camel.spi.RecoverableAggregationRepository
      • getRecoveryIntervalInMillis

        public long getRecoveryIntervalInMillis()
        Specified by:
        getRecoveryIntervalInMillis in interface org.apache.camel.spi.RecoverableAggregationRepository
      • setUseRecovery

        public void setUseRecovery​(boolean useRecovery)
        Specified by:
        setUseRecovery in interface org.apache.camel.spi.RecoverableAggregationRepository
      • isUseRecovery

        public boolean isUseRecovery()
        Specified by:
        isUseRecovery in interface org.apache.camel.spi.RecoverableAggregationRepository
      • setDeadLetterUri

        public void setDeadLetterUri​(String deadLetterUri)
        Specified by:
        setDeadLetterUri in interface org.apache.camel.spi.RecoverableAggregationRepository
      • getDeadLetterUri

        public String getDeadLetterUri()
        Specified by:
        getDeadLetterUri in interface org.apache.camel.spi.RecoverableAggregationRepository
      • setMaximumRedeliveries

        public void setMaximumRedeliveries​(int maximumRedeliveries)
        Specified by:
        setMaximumRedeliveries in interface org.apache.camel.spi.RecoverableAggregationRepository
      • getMaximumRedeliveries

        public int getMaximumRedeliveries()
        Specified by:
        getMaximumRedeliveries in interface org.apache.camel.spi.RecoverableAggregationRepository
      • get

        public org.apache.camel.Exchange get​(org.apache.camel.CamelContext camelContext,
                                             String key)
        Specified by:
        get in interface org.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 interface org.apache.camel.spi.AggregationRepository
        Specified by:
        remove in interface org.apache.camel.spi.OptimisticLockingAggregationRepository
      • confirm

        public void confirm​(org.apache.camel.CamelContext camelContext,
                            String exchangeId)
        Specified by:
        confirm in interface org.apache.camel.spi.AggregationRepository
      • getKeys

        public Set<String> getKeys()
        Specified by:
        getKeys in interface org.apache.camel.spi.AggregationRepository
      • getPersistentRepositoryName

        public String getPersistentRepositoryName()
      • doInit

        protected void doInit()
                       throws Exception
        Overrides:
        doInit in class org.apache.camel.support.service.BaseService
        Throws:
        Exception
      • doStart

        protected void doStart()
                        throws Exception
        Overrides:
        doStart in class org.apache.camel.support.service.BaseService
        Throws:
        Exception
      • doStop

        protected void doStop()
                       throws Exception
        Overrides:
        doStop in class org.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)