org.apache.activemq.store.jdbc
Class Statements
java.lang.Object
org.apache.activemq.store.jdbc.Statements
public class Statements
- extends 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 String messageTableName
durableSubAcksTableName
protected String durableSubAcksTableName
lockTableName
protected String lockTableName
binaryDataType
protected String binaryDataType
containerNameDataType
protected String containerNameDataType
msgIdDataType
protected String msgIdDataType
sequenceDataType
protected String sequenceDataType
longDataType
protected String longDataType
stringIdDataType
protected String stringIdDataType
useExternalMessageReferences
protected boolean useExternalMessageReferences
Statements
public Statements()
getCreateSchemaStatements
public String[] getCreateSchemaStatements()
getDropSchemaStatements
public String[] getDropSchemaStatements()
getAddMessageStatement
public String getAddMessageStatement()
getUpdateMessageStatement
public String getUpdateMessageStatement()
getRemoveMessageStatment
public String getRemoveMessageStatment()
getFindMessageSequenceIdStatement
public String getFindMessageSequenceIdStatement()
getFindMessageStatement
public String getFindMessageStatement()
getFindAllMessagesStatement
public String getFindAllMessagesStatement()
getFindLastSequenceIdInMsgsStatement
public String getFindLastSequenceIdInMsgsStatement()
getFindLastSequenceIdInAcksStatement
public String getFindLastSequenceIdInAcksStatement()
getCreateDurableSubStatement
public String getCreateDurableSubStatement()
getFindDurableSubStatement
public String getFindDurableSubStatement()
getFindAllDurableSubsStatement
public String getFindAllDurableSubsStatement()
getUpdateLastAckOfDurableSubStatement
public String getUpdateLastAckOfDurableSubStatement()
getDeleteSubscriptionStatement
public String getDeleteSubscriptionStatement()
getFindAllDurableSubMessagesStatement
public String getFindAllDurableSubMessagesStatement()
getFindDurableSubMessagesStatement
public String getFindDurableSubMessagesStatement()
findAllDurableSubMessagesStatement
public String findAllDurableSubMessagesStatement()
getNextDurableSubscriberMessageStatement
public String getNextDurableSubscriberMessageStatement()
getDurableSubscriberMessageCountStatement
public String getDurableSubscriberMessageCountStatement()
- Returns:
- the durableSubscriberMessageCountStatement
getNextDurableSubscriberMessageIdStatement
public String getNextDurableSubscriberMessageIdStatement()
- Returns:
- the nextDurableSubscriberMessageIdStatement
getPrevDurableSubscriberMessageIdStatement
public String getPrevDurableSubscriberMessageIdStatement()
- Returns:
- the prevDurableSubscriberMessageIdStatement
getFindAllDestinationsStatement
public String getFindAllDestinationsStatement()
getRemoveAllMessagesStatement
public String getRemoveAllMessagesStatement()
getRemoveAllSubscriptionsStatement
public String getRemoveAllSubscriptionsStatement()
getDeleteOldMessagesStatement
public String getDeleteOldMessagesStatement()
getLockCreateStatement
public String getLockCreateStatement()
getLockUpdateStatement
public String getLockUpdateStatement()
getFullMessageTableName
public String getFullMessageTableName()
getFullAckTableName
public String getFullAckTableName()
getFullLockTableName
public String getFullLockTableName()
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.
getDurableSubAcksTableName
public String getDurableSubAcksTableName()
- Returns:
- Returns the durableSubAcksTableName.
setDurableSubAcksTableName
public void setDurableSubAcksTableName(String durableSubAcksTableName)
- Parameters:
durableSubAcksTableName
- The durableSubAcksTableName to set.
getLockTableName
public String getLockTableName()
setLockTableName
public void setLockTableName(String lockTableName)
getLongDataType
public String getLongDataType()
setLongDataType
public void setLongDataType(String longDataType)
getStringIdDataType
public String getStringIdDataType()
setStringIdDataType
public void setStringIdDataType(String stringIdDataType)
setUseExternalMessageReferences
public void setUseExternalMessageReferences(boolean useExternalMessageReferences)
isUseExternalMessageReferences
public boolean isUseExternalMessageReferences()
setAddMessageStatement
public void setAddMessageStatement(String addMessageStatment)
setCreateDurableSubStatement
public void setCreateDurableSubStatement(String createDurableSubStatment)
setCreateSchemaStatements
public void setCreateSchemaStatements(String[] createSchemaStatments)
setDeleteOldMessagesStatement
public void setDeleteOldMessagesStatement(String deleteOldMessagesStatment)
setDeleteSubscriptionStatement
public void setDeleteSubscriptionStatement(String deleteSubscriptionStatment)
setDropSchemaStatements
public void setDropSchemaStatements(String[] dropSchemaStatments)
setFindAllDestinationsStatement
public void setFindAllDestinationsStatement(String findAllDestinationsStatment)
setFindAllDurableSubMessagesStatement
public void setFindAllDurableSubMessagesStatement(String findAllDurableSubMessagesStatment)
setFindAllDurableSubsStatement
public void setFindAllDurableSubsStatement(String findAllDurableSubsStatment)
setFindAllMessagesStatement
public void setFindAllMessagesStatement(String findAllMessagesStatment)
setFindDurableSubStatement
public void setFindDurableSubStatement(String findDurableSubStatment)
setFindLastSequenceIdInAcksStatement
public void setFindLastSequenceIdInAcksStatement(String findLastSequenceIdInAcks)
setFindLastSequenceIdInMsgsStatement
public void setFindLastSequenceIdInMsgsStatement(String findLastSequenceIdInMsgs)
setFindMessageSequenceIdStatement
public void setFindMessageSequenceIdStatement(String findMessageSequenceIdStatment)
setFindMessageStatement
public void setFindMessageStatement(String findMessageStatment)
setRemoveAllMessagesStatement
public void setRemoveAllMessagesStatement(String removeAllMessagesStatment)
setRemoveAllSubscriptionsStatement
public void setRemoveAllSubscriptionsStatement(String removeAllSubscriptionsStatment)
setRemoveMessageStatment
public void setRemoveMessageStatment(String removeMessageStatment)
setUpdateLastAckOfDurableSubStatement
public void setUpdateLastAckOfDurableSubStatement(String updateLastAckOfDurableSub)
setUpdateMessageStatement
public void setUpdateMessageStatement(String updateMessageStatment)
isUseLockCreateWhereClause
public boolean isUseLockCreateWhereClause()
setUseLockCreateWhereClause
public void setUseLockCreateWhereClause(boolean useLockCreateWhereClause)
setLockCreateStatement
public void setLockCreateStatement(String lockCreateStatement)
setLockUpdateStatement
public void setLockUpdateStatement(String lockUpdateStatement)
setFindDurableSubMessagesStatement
public void setFindDurableSubMessagesStatement(String findDurableSubMessagesStatement)
- Parameters:
findDurableSubMessagesStatement
- the findDurableSubMessagesStatement to set
setNextDurableSubscriberMessageStatement
public void setNextDurableSubscriberMessageStatement(String nextDurableSubscriberMessageStatement)
- Parameters:
nextDurableSubscriberMessageStatement
- the nextDurableSubscriberMessageStatement to set
setDurableSubscriberMessageCountStatement
public void setDurableSubscriberMessageCountStatement(String durableSubscriberMessageCountStatement)
- Parameters:
durableSubscriberMessageCountStatement
- the durableSubscriberMessageCountStatement to set
setNextDurableSubscriberMessageIdStatement
public void setNextDurableSubscriberMessageIdStatement(String nextDurableSubscriberMessageIdStatement)
- Parameters:
nextDurableSubscriberMessageIdStatement
- the nextDurableSubscriberMessageIdStatement to set
setPrevDurableSubscriberMessageIdStatement
public void setPrevDurableSubscriberMessageIdStatement(String prevDurableSubscriberMessageIdStatement)
- Parameters:
prevDurableSubscriberMessageIdStatement
- the prevDurableSubscriberMessageIdStatement to set
Copyright © 2011 Apache Software Foundation. All Rights Reserved.