org.apache.camel.processor.idempotent.jdbc
Class JdbcMessageIdRepository
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.processor.idempotent.jdbc.AbstractJdbcMessageIdRepository<String>
org.apache.camel.processor.idempotent.jdbc.JdbcMessageIdRepository
- All Implemented Interfaces:
- org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.IdempotentRepository<String>, org.apache.camel.StatefulService, org.apache.camel.SuspendableService
public class JdbcMessageIdRepository
- extends AbstractJdbcMessageIdRepository<String>
Default implementation of AbstractJdbcMessageIdRepository
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.processor.idempotent.jdbc.AbstractJdbcMessageIdRepository |
add, confirm, contains, createTransactionTemplate, doStop, getDataSource, getJdbcTemplate, getProcessorName, getTransactionTemplate, remove, setDataSource, setJdbcTemplate, setProcessorName, setTransactionTemplate |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, 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 |
Methods inherited from interface org.apache.camel.Service |
start, stop |
JdbcMessageIdRepository
public JdbcMessageIdRepository()
JdbcMessageIdRepository
public JdbcMessageIdRepository(DataSource dataSource,
String processorName)
JdbcMessageIdRepository
public JdbcMessageIdRepository(DataSource dataSource,
org.springframework.transaction.support.TransactionTemplate transactionTemplate,
String processorName)
JdbcMessageIdRepository
public JdbcMessageIdRepository(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
org.springframework.transaction.support.TransactionTemplate transactionTemplate)
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class AbstractJdbcMessageIdRepository<String>
- Throws:
Exception
queryForInt
protected int queryForInt(String key)
- Description copied from class:
AbstractJdbcMessageIdRepository
- Operation that returns the number of rows, if any, for the specified key
- Specified by:
queryForInt
in class AbstractJdbcMessageIdRepository<String>
- Parameters:
key
- the key
- Returns:
- int number of rows
insert
protected int insert(String key)
- Description copied from class:
AbstractJdbcMessageIdRepository
- Operation that inserts the key if it does not already exist
- Specified by:
insert
in class AbstractJdbcMessageIdRepository<String>
- Parameters:
key
- the key
- Returns:
- int number of rows inserted
delete
protected int delete(String key)
- Description copied from class:
AbstractJdbcMessageIdRepository
- Operations that deletes the key if it exists
- Specified by:
delete
in class AbstractJdbcMessageIdRepository<String>
- Parameters:
key
- the key
- Returns:
- int number of rows deleted
isCreateTableIfNotExists
public boolean isCreateTableIfNotExists()
setCreateTableIfNotExists
public void setCreateTableIfNotExists(boolean createTableIfNotExists)
getTableExistsString
public String getTableExistsString()
setTableExistsString
public void setTableExistsString(String tableExistsString)
getCreateString
public String getCreateString()
setCreateString
public void setCreateString(String createString)
getQueryString
public String getQueryString()
setQueryString
public void setQueryString(String queryString)
getInsertString
public String getInsertString()
setInsertString
public void setInsertString(String insertString)
getDeleteString
public String getDeleteString()
setDeleteString
public void setDeleteString(String deleteString)
Apache Camel