org.apache.activemq.store.jdbc
Class Statements
java.lang.Object
org.apache.activemq.store.jdbc.Statements
public class Statements
- extends java.lang.Object
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()
getDropAckPKAlterStatementEnd
public java.lang.String getDropAckPKAlterStatementEnd()
setDropAckPKAlterStatementEnd
public void setDropAckPKAlterStatementEnd(java.lang.String dropAckPKAlterStatementEnd)
getDropSchemaStatements
public java.lang.String[] getDropSchemaStatements()
getAddMessageStatement
public java.lang.String getAddMessageStatement()
getUpdateMessageStatement
public java.lang.String getUpdateMessageStatement()
getRemoveMessageStatement
public java.lang.String getRemoveMessageStatement()
getFindMessageSequenceIdStatement
public java.lang.String getFindMessageSequenceIdStatement()
getFindMessageStatement
public java.lang.String getFindMessageStatement()
getFindMessageByIdStatement
public java.lang.String getFindMessageByIdStatement()
getFindAllMessagesStatement
public java.lang.String getFindAllMessagesStatement()
getFindAllMessageIdsStatement
public java.lang.String getFindAllMessageIdsStatement()
getFindLastSequenceIdInMsgsStatement
public java.lang.String getFindLastSequenceIdInMsgsStatement()
getLastProducerSequenceIdStatement
public java.lang.String getLastProducerSequenceIdStatement()
getFindLastSequenceIdInAcksStatement
public java.lang.String getFindLastSequenceIdInAcksStatement()
getCreateDurableSubStatement
public java.lang.String getCreateDurableSubStatement()
getFindDurableSubStatement
public java.lang.String getFindDurableSubStatement()
getFindAllDurableSubsStatement
public java.lang.String getFindAllDurableSubsStatement()
getUpdateLastPriorityAckRowOfDurableSubStatement
public java.lang.String getUpdateLastPriorityAckRowOfDurableSubStatement()
getDeleteSubscriptionStatement
public java.lang.String getDeleteSubscriptionStatement()
getFindAllDurableSubMessagesStatement
public java.lang.String getFindAllDurableSubMessagesStatement()
getFindDurableSubMessagesStatement
public java.lang.String getFindDurableSubMessagesStatement()
getFindDurableSubMessagesByPriorityStatement
public java.lang.String getFindDurableSubMessagesByPriorityStatement()
findAllDurableSubMessagesStatement
public java.lang.String findAllDurableSubMessagesStatement()
getNextDurableSubscriberMessageStatement
public java.lang.String getNextDurableSubscriberMessageStatement()
getDurableSubscriberMessageCountStatement
public java.lang.String getDurableSubscriberMessageCountStatement()
- Returns:
- the durableSubscriberMessageCountStatement
getDurableSubscriberMessageCountStatementWithPriority
public java.lang.String getDurableSubscriberMessageCountStatementWithPriority()
getFindAllDestinationsStatement
public java.lang.String getFindAllDestinationsStatement()
getRemoveAllMessagesStatement
public java.lang.String getRemoveAllMessagesStatement()
getRemoveAllSubscriptionsStatement
public java.lang.String getRemoveAllSubscriptionsStatement()
getDeleteOldMessagesStatementWithPriority
public java.lang.String getDeleteOldMessagesStatementWithPriority()
getLockCreateStatement
public java.lang.String getLockCreateStatement()
getLockUpdateStatement
public java.lang.String getLockUpdateStatement()
getDestinationMessageCountStatement
public java.lang.String getDestinationMessageCountStatement()
- Returns:
- the destinationMessageCountStatement
getFindNextMessagesStatement
public java.lang.String getFindNextMessagesStatement()
- Returns:
- the findNextMessagesStatement
getFindNextMessagesByPriorityStatement
public java.lang.String getFindNextMessagesByPriorityStatement()
- Returns:
- the findNextMessagesStatement
getLastAckedDurableSubscriberMessageStatement
public java.lang.String getLastAckedDurableSubscriberMessageStatement()
- Returns:
- the lastAckedDurableSubscriberMessageStatement
getSelectDurablePriorityAckStatement
public java.lang.String getSelectDurablePriorityAckStatement()
getInsertDurablePriorityAckStatement
public java.lang.String getInsertDurablePriorityAckStatement()
getUpdateDurableLastAckStatement
public java.lang.String getUpdateDurableLastAckStatement()
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)
setDeleteOldMessagesStatementWithPriority
public void setDeleteOldMessagesStatementWithPriority(java.lang.String deleteOldMessagesStatementWithPriority)
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)
setFindMessageByIdStatement
public void setFindMessageByIdStatement(java.lang.String findMessageByIdStatement)
setRemoveAllMessagesStatement
public void setRemoveAllMessagesStatement(java.lang.String removeAllMessagesStatment)
setRemoveAllSubscriptionsStatement
public void setRemoveAllSubscriptionsStatement(java.lang.String removeAllSubscriptionsStatment)
setRemoveMessageStatment
public void setRemoveMessageStatment(java.lang.String removeMessageStatement)
setUpdateLastPriorityAckRowOfDurableSubStatement
public void setUpdateLastPriorityAckRowOfDurableSubStatement(java.lang.String updateLastPriorityAckRowOfDurableSubStatement)
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
setDurableSubscriberMessageCountStatementWithPriority
public void setDurableSubscriberMessageCountStatementWithPriority(java.lang.String durableSubscriberMessageCountStatementWithPriority)
setFindNextMessagesStatement
public void setFindNextMessagesStatement(java.lang.String findNextMessagesStatement)
- Parameters:
findNextMessagesStatement
- the findNextMessagesStatement to set
setDestinationMessageCountStatement
public void setDestinationMessageCountStatement(java.lang.String destinationMessageCountStatement)
- Parameters:
destinationMessageCountStatement
- the destinationMessageCountStatement to set
setLastAckedDurableSubscriberMessageStatement
public void setLastAckedDurableSubscriberMessageStatement(java.lang.String lastAckedDurableSubscriberMessageStatement)
- Parameters:
lastAckedDurableSubscriberMessageStatement
- the lastAckedDurableSubscriberMessageStatement to set
setLastProducerSequenceIdStatement
public void setLastProducerSequenceIdStatement(java.lang.String lastProducerSequenceIdStatement)
setSelectDurablePriorityAckStatement
public void setSelectDurablePriorityAckStatement(java.lang.String selectDurablePriorityAckStatement)
setInsertDurablePriorityAckStatement
public void setInsertDurablePriorityAckStatement(java.lang.String insertDurablePriorityAckStatement)
setUpdateDurableLastAckStatement
public void setUpdateDurableLastAckStatement(java.lang.String updateDurableLastAckStatement)
Copyright © 2005-2012. All Rights Reserved.