org.codehaus.activemq.store.jdbc.adapter
Class DefaultStatementProvider
java.lang.Object
org.codehaus.activemq.store.jdbc.adapter.DefaultStatementProvider
- All Implemented Interfaces:
- StatementProvider
- Direct Known Subclasses:
- HsqldbJDBCAdapter.HSQLStatementProvider
- public class DefaultStatementProvider
- extends Object
- implements StatementProvider
- Version:
- $Revision: 1.3 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
tablePrefix
protected String tablePrefix
messageTableName
protected String messageTableName
txTableName
protected String txTableName
durableSubAcksTableName
protected String durableSubAcksTableName
binaryDataType
protected String binaryDataType
containerNameDataType
protected String containerNameDataType
xidDataType
protected String xidDataType
msgIdDataType
protected String msgIdDataType
subscriptionIdDataType
protected String subscriptionIdDataType
sequenceDataType
protected String sequenceDataType
stringIdDataType
protected String stringIdDataType
DefaultStatementProvider
public DefaultStatementProvider()
getCreateSchemaStatments
public String[] getCreateSchemaStatments()
- Specified by:
getCreateSchemaStatments
in interface StatementProvider
getDropSchemaStatments
public String[] getDropSchemaStatments()
- Specified by:
getDropSchemaStatments
in interface StatementProvider
getAddMessageStatment
public String getAddMessageStatment()
- Specified by:
getAddMessageStatment
in interface StatementProvider
getUpdateMessageStatment
public String getUpdateMessageStatment()
- Specified by:
getUpdateMessageStatment
in interface StatementProvider
getRemoveMessageStatment
public String getRemoveMessageStatment()
- Specified by:
getRemoveMessageStatment
in interface StatementProvider
getFindMessageSequenceIdStatment
public String getFindMessageSequenceIdStatment()
- Specified by:
getFindMessageSequenceIdStatment
in interface StatementProvider
getFindMessageStatment
public String getFindMessageStatment()
- Specified by:
getFindMessageStatment
in interface StatementProvider
getFindAllMessagesStatment
public String getFindAllMessagesStatment()
- Specified by:
getFindAllMessagesStatment
in interface StatementProvider
getFindLastSequenceId
public String getFindLastSequenceId()
- Specified by:
getFindLastSequenceId
in interface StatementProvider
getAddXidStatment
public String getAddXidStatment()
- Specified by:
getAddXidStatment
in interface StatementProvider
getUpdateXidStatment
public String getUpdateXidStatment()
- Specified by:
getUpdateXidStatment
in interface StatementProvider
getRemoveXidStatment
public String getRemoveXidStatment()
- Specified by:
getRemoveXidStatment
in interface StatementProvider
getFindXidStatment
public String getFindXidStatment()
- Specified by:
getFindXidStatment
in interface StatementProvider
getFindAllXidStatment
public String getFindAllXidStatment()
- Specified by:
getFindAllXidStatment
in interface StatementProvider
getFindAllTxStatment
public String getFindAllTxStatment()
- Specified by:
getFindAllTxStatment
in interface StatementProvider
getCreateDurableSubStatment
public String getCreateDurableSubStatment()
- Specified by:
getCreateDurableSubStatment
in interface StatementProvider
getUpdateDurableSubStatment
public String getUpdateDurableSubStatment()
- Specified by:
getUpdateDurableSubStatment
in interface StatementProvider
getFindDurableSubStatment
public String getFindDurableSubStatment()
- Specified by:
getFindDurableSubStatment
in interface StatementProvider
getUpdateLastAckOfDurableSub
public String getUpdateLastAckOfDurableSub()
- Specified by:
getUpdateLastAckOfDurableSub
in interface StatementProvider
getFindAllDurableSubMessagesStatment
public String getFindAllDurableSubMessagesStatment()
- Specified by:
getFindAllDurableSubMessagesStatment
in interface StatementProvider
getRemoveAllMessagesStatment
public String getRemoveAllMessagesStatment()
- Specified by:
getRemoveAllMessagesStatment
in interface StatementProvider
getRemoveAllSubscriptionsStatment
public String getRemoveAllSubscriptionsStatment()
- Specified by:
getRemoveAllSubscriptionsStatment
in interface StatementProvider
getContainerNameDataType
public String getContainerNameDataType()
- Returns:
- Returns the containerNameDataType.
setContainerNameDataType
public void setContainerNameDataType(String containerNameDataType)
- Parameters:
containerNameDataType
- The containerNameDataType to set.
getBinaryDataType
public String getBinaryDataType()
- Returns:
- Returns the messageDataType.
setBinaryDataType
public void setBinaryDataType(String messageDataType)
- Parameters:
messageDataType
- The messageDataType to set.
getMessageTableName
public String getMessageTableName()
- Returns:
- Returns the messageTableName.
setMessageTableName
public void setMessageTableName(String messageTableName)
- Parameters:
messageTableName
- The messageTableName to set.
getMsgIdDataType
public String getMsgIdDataType()
- Returns:
- Returns the msgIdDataType.
setMsgIdDataType
public void setMsgIdDataType(String msgIdDataType)
- Parameters:
msgIdDataType
- The msgIdDataType to set.
getSequenceDataType
public String getSequenceDataType()
- Returns:
- Returns the sequenceDataType.
setSequenceDataType
public void setSequenceDataType(String sequenceDataType)
- Parameters:
sequenceDataType
- The sequenceDataType to set.
getTablePrefix
public String getTablePrefix()
- Returns:
- Returns the tablePrefix.
setTablePrefix
public void setTablePrefix(String tablePrefix)
- Parameters:
tablePrefix
- The tablePrefix to set.
getTxTableName
public String getTxTableName()
- Returns:
- Returns the txTableName.
setTxTableName
public void setTxTableName(String txTableName)
- Parameters:
txTableName
- The txTableName to set.
getXidDataType
public String getXidDataType()
- Returns:
- Returns the xidDataType.
setXidDataType
public void setXidDataType(String xidDataType)
- Parameters:
xidDataType
- The xidDataType to set.
getDurableSubAcksTableName
public String getDurableSubAcksTableName()
- Returns:
- Returns the durableSubAcksTableName.
setDurableSubAcksTableName
public void setDurableSubAcksTableName(String durableSubAcksTableName)
- Parameters:
durableSubAcksTableName
- The durableSubAcksTableName to set.
getSubscriptionIdDataType
public String getSubscriptionIdDataType()
- Returns:
- Returns the subscriptionIdDataType.
setSubscriptionIdDataType
public void setSubscriptionIdDataType(String subscriptionIdDataType)
- Parameters:
subscriptionIdDataType
- The subscriptionIdDataType to set.
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.