Class LevelDBAggregationRepository
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.component.leveldb.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.UseLevelDBAggregationRepository
from component camel-leveldb.An instance ofAggregationRepository
which is backed by aLevelDBFile
.
-
-
Constructor Summary
Constructors Constructor Description LevelDBAggregationRepository()
Deprecated.Creates an aggregation repositoryLevelDBAggregationRepository(String repositoryName)
Deprecated.Creates an aggregation repositoryLevelDBAggregationRepository(String repositoryName, String persistentFileName)
Deprecated.Creates an aggregation repository using a newLevelDBFile
that persists using the provided file.LevelDBAggregationRepository(String repositoryName, LevelDBFile levelDBFile)
Deprecated.Creates an aggregation repository using the providedLevelDBFile
.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description org.apache.camel.Exchange
add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
Deprecated.static String
asString(byte[] value)
Deprecated.void
confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
Deprecated.protected void
doStart()
Deprecated.protected void
doStop()
Deprecated.org.apache.camel.Exchange
get(org.apache.camel.CamelContext camelContext, String key)
Deprecated.String
getDeadLetterUri()
Deprecated.Set<String>
getKeys()
Deprecated.LevelDBFile
getLevelDBFile()
Deprecated.int
getMaximumRedeliveries()
Deprecated.String
getPersistentFileName()
Deprecated.long
getRecoveryIntervalInMillis()
Deprecated.String
getRepositoryName()
Deprecated.boolean
isAllowSerializedHeaders()
Deprecated.boolean
isReturnOldExchange()
Deprecated.boolean
isSync()
Deprecated.boolean
isUseRecovery()
Deprecated.static byte[]
keyBuilder(String repo, String key)
Deprecated.org.apache.camel.Exchange
recover(org.apache.camel.CamelContext camelContext, String exchangeId)
Deprecated.void
remove(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
Deprecated.Set<String>
scan(org.apache.camel.CamelContext camelContext)
Deprecated.void
setAllowSerializedHeaders(boolean allowSerializedHeaders)
Deprecated.void
setDeadLetterUri(String deadLetterUri)
Deprecated.void
setLevelDBFile(LevelDBFile levelDBFile)
Deprecated.void
setMaximumRedeliveries(int maximumRedeliveries)
Deprecated.void
setPersistentFileName(String persistentFileName)
Deprecated.void
setRecoveryInterval(long interval)
Deprecated.void
setRecoveryInterval(long interval, TimeUnit timeUnit)
Deprecated.void
setRepositoryName(String repositoryName)
Deprecated.void
setReturnOldExchange(boolean returnOldExchange)
Deprecated.void
setSync(boolean sync)
Deprecated.void
setUseRecovery(boolean useRecovery)
Deprecated.-
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
-
-
-
-
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 newLevelDBFile
that persists using the provided file.- Parameters:
repositoryName
- the repository namepersistentFileName
- the persistent store filename
-
LevelDBAggregationRepository
public LevelDBAggregationRepository(String repositoryName, LevelDBFile levelDBFile)
Deprecated.Creates an aggregation repository using the providedLevelDBFile
.- Parameters:
repositoryName
- the repository namelevelDBFile
- 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 interfaceorg.apache.camel.spi.AggregationRepository
-
get
public org.apache.camel.Exchange get(org.apache.camel.CamelContext camelContext, String key)
Deprecated.- 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)
Deprecated.- Specified by:
remove
in interfaceorg.apache.camel.spi.AggregationRepository
-
confirm
public void confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
Deprecated.- Specified by:
confirm
in interfaceorg.apache.camel.spi.AggregationRepository
-
getKeys
public Set<String> getKeys()
Deprecated.- Specified by:
getKeys
in interfaceorg.apache.camel.spi.AggregationRepository
-
scan
public Set<String> scan(org.apache.camel.CamelContext camelContext)
Deprecated.- Specified by:
scan
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
recover
public org.apache.camel.Exchange recover(org.apache.camel.CamelContext camelContext, String exchangeId)
Deprecated.- Specified by:
recover
in interfaceorg.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 interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setRecoveryInterval
public void setRecoveryInterval(long interval)
Deprecated.- Specified by:
setRecoveryInterval
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
getRecoveryIntervalInMillis
public long getRecoveryIntervalInMillis()
Deprecated.- Specified by:
getRecoveryIntervalInMillis
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
isUseRecovery
public boolean isUseRecovery()
Deprecated.- Specified by:
isUseRecovery
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setUseRecovery
public void setUseRecovery(boolean useRecovery)
Deprecated.- Specified by:
setUseRecovery
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
getMaximumRedeliveries
public int getMaximumRedeliveries()
Deprecated.- Specified by:
getMaximumRedeliveries
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setMaximumRedeliveries
public void setMaximumRedeliveries(int maximumRedeliveries)
Deprecated.- Specified by:
setMaximumRedeliveries
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
getDeadLetterUri
public String getDeadLetterUri()
Deprecated.- Specified by:
getDeadLetterUri
in interfaceorg.apache.camel.spi.RecoverableAggregationRepository
-
setDeadLetterUri
public void setDeadLetterUri(String deadLetterUri)
Deprecated.- Specified by:
setDeadLetterUri
in interfaceorg.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 classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
Deprecated.- Overrides:
doStop
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
asString
public static String asString(byte[] value)
Deprecated.
-
-