org.apache.camel.processor.idempotent.jdbc
Class JdbcMessageIdRepository

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.processor.idempotent.jdbc.AbstractJdbcMessageIdRepository<String>
          extended by 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


Field Summary
 
Fields inherited from class org.apache.camel.processor.idempotent.jdbc.AbstractJdbcMessageIdRepository
dataSource, jdbcTemplate, log, processorName, transactionTemplate
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
JdbcMessageIdRepository()
           
JdbcMessageIdRepository(DataSource dataSource, String processorName)
           
JdbcMessageIdRepository(DataSource dataSource, org.springframework.transaction.support.TransactionTemplate transactionTemplate, String processorName)
           
JdbcMessageIdRepository(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, org.springframework.transaction.support.TransactionTemplate transactionTemplate)
           
 
Method Summary
protected  int delete(String key)
          Operations that deletes the key if it exists
protected  void doStart()
           
 String getCreateString()
           
 String getDeleteString()
           
 String getInsertString()
           
 String getQueryString()
           
 String getTableExistsString()
           
protected  int insert(String key)
          Operation that inserts the key if it does not already exist
 boolean isCreateTableIfNotExists()
           
protected  int queryForInt(String key)
          Operation that returns the number of rows, if any, for the specified key
 void setCreateString(String createString)
           
 void setCreateTableIfNotExists(boolean createTableIfNotExists)
           
 void setDeleteString(String deleteString)
           
 void setInsertString(String insertString)
           
 void setQueryString(String queryString)
           
 void setTableExistsString(String tableExistsString)
           
 
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
 

Constructor Detail

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)
Method Detail

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