Class 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
    • Field Summary

      • Fields inherited from class org.apache.camel.support.service.BaseService

        BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING
    • Constructor Detail

      • CaffeineAggregationRepository

        public CaffeineAggregationRepository()
    • 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 interface org.apache.camel.spi.RecoverableAggregationRepository
      • getDeadLetterUri

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

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

        public void setUseRecovery​(boolean useRecovery)
        Specified by:
        setUseRecovery in interface org.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 interface org.apache.camel.spi.RecoverableAggregationRepository
      • setRecoveryInterval

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

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

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

        public void setMaximumRedeliveries​(int maximumRedeliveries)
        Specified by:
        setMaximumRedeliveries in interface org.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 interface org.apache.camel.spi.AggregationRepository
      • get

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

        public static org.apache.camel.Exchange unmarshallExchange​(org.apache.camel.CamelContext camelContext,
                                                                   org.apache.camel.support.DefaultExchangeHolder holder)