public class HawtDBAggregationRepository
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.RecoverableAggregationRepository, org.apache.camel.spi.OptimisticLockingAggregationRepository
Constructor and Description |
---|
HawtDBAggregationRepository()
Creates an aggregation repository
|
HawtDBAggregationRepository(String repositoryName)
Creates an aggregation repository
|
HawtDBAggregationRepository(String repositoryName,
HawtDBFile hawtDBFile)
Creates an aggregation repository using the provided
HawtDBFile . |
HawtDBAggregationRepository(String repositoryName,
String persistentFileName)
Creates an aggregation repository using a new
HawtDBFile
that persists using the provided file. |
Modifier and Type | Method and 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) |
protected org.apache.camel.Exchange |
doAdd(org.apache.camel.CamelContext camelContext,
String key,
org.apache.camel.Exchange exchange,
boolean handleOptimisticLockingException) |
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.Exchange |
get(org.apache.camel.CamelContext camelContext,
String key) |
Integer |
getBufferSize() |
String |
getDeadLetterUri() |
HawtDBFile |
getHawtDBFile() |
Set<String> |
getKeys() |
int |
getMaximumRedeliveries() |
short |
getPageSize() |
String |
getPersistentFileName() |
long |
getRecoveryIntervalInMillis() |
String |
getRepositoryName() |
boolean |
isAllowSerializedHeaders() |
boolean |
isReturnOldExchange() |
boolean |
isSync() |
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 |
setBufferSize(Integer bufferSize) |
void |
setDeadLetterUri(String deadLetterUri) |
void |
setHawtDBFile(HawtDBFile hawtDBFile) |
void |
setMaximumRedeliveries(int maximumRedeliveries) |
void |
setPageSize(short pageSize) |
void |
setPersistentFileName(String persistentFileName) |
void |
setRecoveryInterval(long interval) |
void |
setRecoveryInterval(long interval,
TimeUnit timeUnit) |
void |
setRepositoryName(String repositoryName) |
void |
setReturnOldExchange(boolean returnOldExchange) |
void |
setSync(boolean sync) |
void |
setUseRecovery(boolean useRecovery) |
public HawtDBAggregationRepository()
public HawtDBAggregationRepository(String repositoryName)
repositoryName
- the repository namepublic HawtDBAggregationRepository(String repositoryName, String persistentFileName)
HawtDBFile
that persists using the provided file.repositoryName
- the repository namepersistentFileName
- the persistent store filenamepublic HawtDBAggregationRepository(String repositoryName, HawtDBFile hawtDBFile)
HawtDBFile
.repositoryName
- the repository namehawtDBFile
- the hawtdb file to use as persistent storepublic org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
add
in interface org.apache.camel.spi.AggregationRepository
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
add
in interface org.apache.camel.spi.OptimisticLockingAggregationRepository
org.apache.camel.spi.OptimisticLockingAggregationRepository.OptimisticLockingException
protected org.apache.camel.Exchange doAdd(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange, boolean handleOptimisticLockingException)
public org.apache.camel.Exchange get(org.apache.camel.CamelContext camelContext, String key)
get
in interface org.apache.camel.spi.AggregationRepository
public void remove(org.apache.camel.CamelContext camelContext, String key, org.apache.camel.Exchange exchange)
remove
in interface org.apache.camel.spi.AggregationRepository
remove
in interface org.apache.camel.spi.OptimisticLockingAggregationRepository
public void confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
confirm
in interface org.apache.camel.spi.AggregationRepository
public Set<String> getKeys()
getKeys
in interface org.apache.camel.spi.AggregationRepository
public Set<String> scan(org.apache.camel.CamelContext camelContext)
scan
in interface org.apache.camel.spi.RecoverableAggregationRepository
public org.apache.camel.Exchange recover(org.apache.camel.CamelContext camelContext, String exchangeId)
recover
in interface org.apache.camel.spi.RecoverableAggregationRepository
public HawtDBFile getHawtDBFile()
public void setHawtDBFile(HawtDBFile hawtDBFile)
public String getRepositoryName()
public void setRepositoryName(String repositoryName)
public String getPersistentFileName()
public void setPersistentFileName(String persistentFileName)
public boolean isSync()
public void setSync(boolean sync)
public Integer getBufferSize()
public void setBufferSize(Integer bufferSize)
public boolean isReturnOldExchange()
public void setReturnOldExchange(boolean returnOldExchange)
public void setRecoveryInterval(long interval, TimeUnit timeUnit)
setRecoveryInterval
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setRecoveryInterval(long interval)
setRecoveryInterval
in interface org.apache.camel.spi.RecoverableAggregationRepository
public long getRecoveryIntervalInMillis()
getRecoveryIntervalInMillis
in interface org.apache.camel.spi.RecoverableAggregationRepository
public boolean isUseRecovery()
isUseRecovery
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setUseRecovery(boolean useRecovery)
setUseRecovery
in interface org.apache.camel.spi.RecoverableAggregationRepository
public int getMaximumRedeliveries()
getMaximumRedeliveries
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setMaximumRedeliveries(int maximumRedeliveries)
setMaximumRedeliveries
in interface org.apache.camel.spi.RecoverableAggregationRepository
public String getDeadLetterUri()
getDeadLetterUri
in interface org.apache.camel.spi.RecoverableAggregationRepository
public void setDeadLetterUri(String deadLetterUri)
setDeadLetterUri
in interface org.apache.camel.spi.RecoverableAggregationRepository
public short getPageSize()
public void setPageSize(short pageSize)
public boolean isAllowSerializedHeaders()
public void setAllowSerializedHeaders(boolean allowSerializedHeaders)
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
Apache Camel