Class LevelDBAggregationRepository

  • 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

    @Deprecated
    public class LevelDBAggregationRepository
    extends org.apache.camel.support.service.ServiceSupport
    implements org.apache.camel.spi.RecoverableAggregationRepository
    Deprecated.
    Use LevelDBAggregationRepository from component camel-leveldb.
    An instance of AggregationRepository which is backed by a LevelDBFile.
    • Constructor Detail

      • LevelDBAggregationRepository

        public LevelDBAggregationRepository()
        Deprecated.
        Creates an aggregation repository
      • LevelDBAggregationRepository

        public LevelDBAggregationRepository​(String repositoryName)
        Deprecated.
        Creates an aggregation repository
        Parameters:
        repositoryName - the repository name
      • LevelDBAggregationRepository

        public LevelDBAggregationRepository​(String repositoryName,
                                            String persistentFileName)
        Deprecated.
        Creates an aggregation repository using a new LevelDBFile that persists using the provided file.
        Parameters:
        repositoryName - the repository name
        persistentFileName - the persistent store filename
      • LevelDBAggregationRepository

        public LevelDBAggregationRepository​(String repositoryName,
                                            LevelDBFile levelDBFile)
        Deprecated.
        Creates an aggregation repository using the provided LevelDBFile.
        Parameters:
        repositoryName - the repository name
        levelDBFile - the leveldb file to use as persistent store
    • Method Detail

      • add

        public org.apache.camel.Exchange add​(org.apache.camel.CamelContext camelContext,
                                             String key,
                                             org.apache.camel.Exchange exchange)
        Deprecated.
        Specified by:
        add in interface org.apache.camel.spi.AggregationRepository
      • get

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

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

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

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

        public org.apache.camel.Exchange recover​(org.apache.camel.CamelContext camelContext,
                                                 String exchangeId)
        Deprecated.
        Specified by:
        recover in interface org.apache.camel.spi.RecoverableAggregationRepository
      • getLevelDBFile

        public LevelDBFile getLevelDBFile()
        Deprecated.
      • setLevelDBFile

        public void setLevelDBFile​(LevelDBFile levelDBFile)
        Deprecated.
      • getRepositoryName

        public String getRepositoryName()
        Deprecated.
      • setRepositoryName

        public void setRepositoryName​(String repositoryName)
        Deprecated.
      • isSync

        public boolean isSync()
        Deprecated.
      • setSync

        public void setSync​(boolean sync)
        Deprecated.
      • isReturnOldExchange

        public boolean isReturnOldExchange()
        Deprecated.
      • setReturnOldExchange

        public void setReturnOldExchange​(boolean returnOldExchange)
        Deprecated.
      • setRecoveryInterval

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

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

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

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

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

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

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

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

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

        public String getPersistentFileName()
        Deprecated.
      • setPersistentFileName

        public void setPersistentFileName​(String persistentFileName)
        Deprecated.
      • isAllowSerializedHeaders

        public boolean isAllowSerializedHeaders()
        Deprecated.
      • setAllowSerializedHeaders

        public void setAllowSerializedHeaders​(boolean allowSerializedHeaders)
        Deprecated.
      • doStart

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

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

        public static byte[] keyBuilder​(String repo,
                                        String key)
        Deprecated.
      • asString

        public static String asString​(byte[] value)
        Deprecated.