org.apache.camel.processor.aggregate.jdbc
Class JdbcAggregationRepository
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository
- All Implemented Interfaces:
- 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 JdbcAggregationRepository
- extends org.apache.camel.support.ServiceSupport
- implements org.apache.camel.spi.RecoverableAggregationRepository
JDBC based AggregationRepository
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JdbcAggregationRepository
public JdbcAggregationRepository()
- Creates an aggregation repository
JdbcAggregationRepository
public JdbcAggregationRepository(org.springframework.transaction.PlatformTransactionManager transactionManager,
String repositoryName,
DataSource dataSource)
- Creates an aggregation repository with the three mandatory parameters
setRepositoryName
public final void setRepositoryName(String repositoryName)
- Parameters:
repositoryName
- the repositoryName to set
setTransactionManager
public final void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
setDataSource
public final void setDataSource(DataSource dataSource)
add
public org.apache.camel.Exchange add(org.apache.camel.CamelContext camelContext,
String correlationId,
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 correlationId)
- Specified by:
get
in interface org.apache.camel.spi.AggregationRepository
remove
public void remove(org.apache.camel.CamelContext camelContext,
String correlationId,
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
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
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
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
getDeadLetterUri
public String getDeadLetterUri()
- Specified by:
getDeadLetterUri
in interface org.apache.camel.spi.RecoverableAggregationRepository
setDeadLetterUri
public void setDeadLetterUri(String deadLetterUri)
- Specified by:
setDeadLetterUri
in interface org.apache.camel.spi.RecoverableAggregationRepository
isReturnOldExchange
public boolean isReturnOldExchange()
setReturnOldExchange
public void setReturnOldExchange(boolean returnOldExchange)
getLobHandler
public org.springframework.jdbc.support.lob.LobHandler getLobHandler()
- Returns:
- the lobHandler
setLobHandler
public void setLobHandler(org.springframework.jdbc.support.lob.LobHandler lobHandler)
- Parameters:
lobHandler
- the lobHandler to set
getRepositoryName
public String getRepositoryName()
getRepositoryNameCompleted
public String getRepositoryNameCompleted()
doStart
protected void doStart()
throws Exception
- Specified by:
doStart
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Specified by:
doStop
in class org.apache.camel.support.ServiceSupport
- Throws:
Exception
Apache CAMEL