org.apache.activemq.store.jdbc
Class Statements
java.lang.Object
org.apache.activemq.store.jdbc.Statements
public class Statements
- extends java.lang.Object
- Version:
- $Revision: 1.4 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
messageTableName
protected java.lang.String messageTableName
durableSubAcksTableName
protected java.lang.String durableSubAcksTableName
lockTableName
protected java.lang.String lockTableName
binaryDataType
protected java.lang.String binaryDataType
containerNameDataType
protected java.lang.String containerNameDataType
msgIdDataType
protected java.lang.String msgIdDataType
sequenceDataType
protected java.lang.String sequenceDataType
longDataType
protected java.lang.String longDataType
stringIdDataType
protected java.lang.String stringIdDataType
useExternalMessageReferences
protected boolean useExternalMessageReferences
Statements
public Statements()
getCreateSchemaStatements
public java.lang.String[] getCreateSchemaStatements()
getDropSchemaStatements
public java.lang.String[] getDropSchemaStatements()
getAddMessageStatement
public java.lang.String getAddMessageStatement()
getUpdateMessageStatement
public java.lang.String getUpdateMessageStatement()
getRemoveMessageStatment
public java.lang.String getRemoveMessageStatment()
getFindMessageSequenceIdStatement
public java.lang.String getFindMessageSequenceIdStatement()
getFindMessageStatement
public java.lang.String getFindMessageStatement()
getFindAllMessagesStatement
public java.lang.String getFindAllMessagesStatement()
getFindLastSequenceIdInMsgsStatement
public java.lang.String getFindLastSequenceIdInMsgsStatement()
getFindLastSequenceIdInAcksStatement
public java.lang.String getFindLastSequenceIdInAcksStatement()
getCreateDurableSubStatement
public java.lang.String getCreateDurableSubStatement()
getFindDurableSubStatement
public java.lang.String getFindDurableSubStatement()
getFindAllDurableSubsStatement
public java.lang.String getFindAllDurableSubsStatement()
getUpdateLastAckOfDurableSubStatement
public java.lang.String getUpdateLastAckOfDurableSubStatement()
getDeleteSubscriptionStatement
public java.lang.String getDeleteSubscriptionStatement()
getFindAllDurableSubMessagesStatement
public java.lang.String getFindAllDurableSubMessagesStatement()
getFindDurableSubMessagesStatement
public java.lang.String getFindDurableSubMessagesStatement()
findAllDurableSubMessagesStatement
public java.lang.String findAllDurableSubMessagesStatement()
getNextDurableSubscriberMessageStatement
public java.lang.String getNextDurableSubscriberMessageStatement()
getDurableSubscriberMessageCountStatement
public java.lang.String getDurableSubscriberMessageCountStatement()
- Returns:
- the durableSubscriberMessageCountStatement
getNextDurableSubscriberMessageIdStatement
public java.lang.String getNextDurableSubscriberMessageIdStatement()
- Returns:
- the nextDurableSubscriberMessageIdStatement
getPrevDurableSubscriberMessageIdStatement
public java.lang.String getPrevDurableSubscriberMessageIdStatement()
- Returns:
- the prevDurableSubscriberMessageIdStatement
getFindAllDestinationsStatement
public java.lang.String getFindAllDestinationsStatement()
getRemoveAllMessagesStatement
public java.lang.String getRemoveAllMessagesStatement()
getRemoveAllSubscriptionsStatement
public java.lang.String getRemoveAllSubscriptionsStatement()
getDeleteOldMessagesStatement
public java.lang.String getDeleteOldMessagesStatement()
getLockCreateStatement
public java.lang.String getLockCreateStatement()
getLockUpdateStatement
public java.lang.String getLockUpdateStatement()
getFullMessageTableName
public java.lang.String getFullMessageTableName()
getFullAckTableName
public java.lang.String getFullAckTableName()
getFullLockTableName
public java.lang.String getFullLockTableName()
getContainerNameDataType
public java.lang.String getContainerNameDataType()
- Returns:
- Returns the containerNameDataType.
setContainerNameDataType
public void setContainerNameDataType(java.lang.String containerNameDataType)
- Parameters:
containerNameDataType
- The containerNameDataType to set.
getBinaryDataType
public java.lang.String getBinaryDataType()
- Returns:
- Returns the messageDataType.
setBinaryDataType
public void setBinaryDataType(java.lang.String messageDataType)
- Parameters:
messageDataType
- The messageDataType to set.
getMessageTableName
public java.lang.String getMessageTableName()
- Returns:
- Returns the messageTableName.
setMessageTableName
public void setMessageTableName(java.lang.String messageTableName)
- Parameters:
messageTableName
- The messageTableName to set.
getMsgIdDataType
public java.lang.String getMsgIdDataType()
- Returns:
- Returns the msgIdDataType.
setMsgIdDataType
public void setMsgIdDataType(java.lang.String msgIdDataType)
- Parameters:
msgIdDataType
- The msgIdDataType to set.
getSequenceDataType
public java.lang.String getSequenceDataType()
- Returns:
- Returns the sequenceDataType.
setSequenceDataType
public void setSequenceDataType(java.lang.String sequenceDataType)
- Parameters:
sequenceDataType
- The sequenceDataType to set.
getTablePrefix
public java.lang.String getTablePrefix()
- Returns:
- Returns the tablePrefix.
setTablePrefix
public void setTablePrefix(java.lang.String tablePrefix)
- Parameters:
tablePrefix
- The tablePrefix to set.
getDurableSubAcksTableName
public java.lang.String getDurableSubAcksTableName()
- Returns:
- Returns the durableSubAcksTableName.
setDurableSubAcksTableName
public void setDurableSubAcksTableName(java.lang.String durableSubAcksTableName)
- Parameters:
durableSubAcksTableName
- The durableSubAcksTableName to set.
getLockTableName
public java.lang.String getLockTableName()
setLockTableName
public void setLockTableName(java.lang.String lockTableName)
getLongDataType
public java.lang.String getLongDataType()
setLongDataType
public void setLongDataType(java.lang.String longDataType)
getStringIdDataType
public java.lang.String getStringIdDataType()
setStringIdDataType
public void setStringIdDataType(java.lang.String stringIdDataType)
setUseExternalMessageReferences
public void setUseExternalMessageReferences(boolean useExternalMessageReferences)
isUseExternalMessageReferences
public boolean isUseExternalMessageReferences()
setAddMessageStatement
public void setAddMessageStatement(java.lang.String addMessageStatment)
setCreateDurableSubStatement
public void setCreateDurableSubStatement(java.lang.String createDurableSubStatment)
setCreateSchemaStatements
public void setCreateSchemaStatements(java.lang.String[] createSchemaStatments)
setDeleteOldMessagesStatement
public void setDeleteOldMessagesStatement(java.lang.String deleteOldMessagesStatment)
setDeleteSubscriptionStatement
public void setDeleteSubscriptionStatement(java.lang.String deleteSubscriptionStatment)
setDropSchemaStatements
public void setDropSchemaStatements(java.lang.String[] dropSchemaStatments)
setFindAllDestinationsStatement
public void setFindAllDestinationsStatement(java.lang.String findAllDestinationsStatment)
setFindAllDurableSubMessagesStatement
public void setFindAllDurableSubMessagesStatement(java.lang.String findAllDurableSubMessagesStatment)
setFindAllDurableSubsStatement
public void setFindAllDurableSubsStatement(java.lang.String findAllDurableSubsStatment)
setFindAllMessagesStatement
public void setFindAllMessagesStatement(java.lang.String findAllMessagesStatment)
setFindDurableSubStatement
public void setFindDurableSubStatement(java.lang.String findDurableSubStatment)
setFindLastSequenceIdInAcksStatement
public void setFindLastSequenceIdInAcksStatement(java.lang.String findLastSequenceIdInAcks)
setFindLastSequenceIdInMsgsStatement
public void setFindLastSequenceIdInMsgsStatement(java.lang.String findLastSequenceIdInMsgs)
setFindMessageSequenceIdStatement
public void setFindMessageSequenceIdStatement(java.lang.String findMessageSequenceIdStatment)
setFindMessageStatement
public void setFindMessageStatement(java.lang.String findMessageStatment)
setRemoveAllMessagesStatement
public void setRemoveAllMessagesStatement(java.lang.String removeAllMessagesStatment)
setRemoveAllSubscriptionsStatement
public void setRemoveAllSubscriptionsStatement(java.lang.String removeAllSubscriptionsStatment)
setRemoveMessageStatment
public void setRemoveMessageStatment(java.lang.String removeMessageStatment)
setUpdateLastAckOfDurableSubStatement
public void setUpdateLastAckOfDurableSubStatement(java.lang.String updateLastAckOfDurableSub)
setUpdateMessageStatement
public void setUpdateMessageStatement(java.lang.String updateMessageStatment)
isUseLockCreateWhereClause
public boolean isUseLockCreateWhereClause()
setUseLockCreateWhereClause
public void setUseLockCreateWhereClause(boolean useLockCreateWhereClause)
setLockCreateStatement
public void setLockCreateStatement(java.lang.String lockCreateStatement)
setLockUpdateStatement
public void setLockUpdateStatement(java.lang.String lockUpdateStatement)
setFindDurableSubMessagesStatement
public void setFindDurableSubMessagesStatement(java.lang.String findDurableSubMessagesStatement)
- Parameters:
findDurableSubMessagesStatement
- the findDurableSubMessagesStatement to set
setNextDurableSubscriberMessageStatement
public void setNextDurableSubscriberMessageStatement(java.lang.String nextDurableSubscriberMessageStatement)
- Parameters:
nextDurableSubscriberMessageStatement
- the nextDurableSubscriberMessageStatement to set
setDurableSubscriberMessageCountStatement
public void setDurableSubscriberMessageCountStatement(java.lang.String durableSubscriberMessageCountStatement)
- Parameters:
durableSubscriberMessageCountStatement
- the durableSubscriberMessageCountStatement to set
setNextDurableSubscriberMessageIdStatement
public void setNextDurableSubscriberMessageIdStatement(java.lang.String nextDurableSubscriberMessageIdStatement)
- Parameters:
nextDurableSubscriberMessageIdStatement
- the nextDurableSubscriberMessageIdStatement to set
setPrevDurableSubscriberMessageIdStatement
public void setPrevDurableSubscriberMessageIdStatement(java.lang.String prevDurableSubscriberMessageIdStatement)
- Parameters:
prevDurableSubscriberMessageIdStatement
- the prevDurableSubscriberMessageIdStatement to set
Copyright © 2009 Apache Software Foundation. All Rights Reserved.