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

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
JdbcAggregationRepository() Creates an aggregation repository
JdbcAggregationRepository(org.springframework.transaction.PlatformTransactionManager transactionManager, String repositoryName, DataSource dataSource) Creates an aggregation repository with the three mandatory parameters

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.camel.Exchange	add(org.apache.camel.CamelContext camelContext, String correlationId, org.apache.camel.Exchange exchange)
void	confirm(org.apache.camel.CamelContext camelContext, String exchangeId)
protected void	doStart()
protected void	doStop()
org.apache.camel.Exchange	get(org.apache.camel.CamelContext camelContext, String correlationId)
String	getDeadLetterUri()
Set<String>	getKeys()
org.springframework.jdbc.support.lob.LobHandler	getLobHandler()
int	getMaximumRedeliveries()
long	getRecoveryIntervalInMillis()
String	getRepositoryName()
String	getRepositoryNameCompleted()
boolean	isReturnOldExchange()
boolean	isUseRecovery()
org.apache.camel.Exchange	recover(org.apache.camel.CamelContext camelContext, String exchangeId)
void	remove(org.apache.camel.CamelContext camelContext, String correlationId, org.apache.camel.Exchange exchange)
Set<String>	scan(org.apache.camel.CamelContext camelContext)
void	setDataSource(DataSource dataSource)
void	setDeadLetterUri(String deadLetterUri)
void	setLobHandler(org.springframework.jdbc.support.lob.LobHandler lobHandler)
void	setMaximumRedeliveries(int maximumRedeliveries)
void	setRecoveryInterval(long interval)
void	setRecoveryInterval(long interval, TimeUnit timeUnit)
void	setRepositoryName(String repositoryName)
void	setReturnOldExchange(boolean returnOldExchange)
void	setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
void	setUseRecovery(boolean useRecovery)

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

Constructor Detail

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

Method Detail

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