public class Statements extends Object
Modifier and Type | Field and Description |
---|---|
protected String |
binaryDataType |
protected String |
containerNameDataType |
protected String |
durableSubAcksTableName |
protected String |
lockTableName |
protected String |
longDataType |
protected String |
messageTableName |
protected String |
msgIdDataType |
protected String |
sequenceDataType |
protected String |
stringIdDataType |
protected boolean |
useExternalMessageReferences |
Constructor and Description |
---|
Statements() |
protected String messageTableName
protected String durableSubAcksTableName
protected String lockTableName
protected String binaryDataType
protected String containerNameDataType
protected String msgIdDataType
protected String sequenceDataType
protected String longDataType
protected String stringIdDataType
protected boolean useExternalMessageReferences
public Statements()
public String[] getCreateSchemaStatements()
public String[] getCreateLockSchemaStatements()
public String getDropAckPKAlterStatementEnd()
public void setDropAckPKAlterStatementEnd(String dropAckPKAlterStatementEnd)
public String[] getDropSchemaStatements()
public String getAddMessageStatement()
public String getUpdateMessageStatement()
public String getRemoveMessageStatement()
public String getFindMessageSequenceIdStatement()
public String getFindMessageStatement()
public String getFindMessageByIdStatement()
public String getFindXidByIdStatement()
public String getFindAllMessagesStatement()
public String getFindAllMessageIdsStatement()
public void setFindAllMessageIdsStatement(String val)
public String getFindLastSequenceIdInMsgsStatement()
public String getLastProducerSequenceIdStatement()
public String getFindLastSequenceIdInAcksStatement()
public String getCreateDurableSubStatement()
public String getFindDurableSubStatement()
public String getFindAllDurableSubsStatement()
public String getUpdateLastPriorityAckRowOfDurableSubStatement()
public String getDeleteSubscriptionStatement()
public String getFindAllDurableSubMessagesStatement()
public String getFindDurableSubMessagesStatement()
public String getFindDurableSubMessagesByPriorityStatement()
public String getNextDurableSubscriberMessageStatement()
public String getDurableSubscriberMessageCountStatement()
public String getDurableSubscriberMessageCountStatementWithPriority()
public String getFindAllDestinationsStatement()
public String getRemoveAllMessagesStatement()
public String getRemoveAllSubscriptionsStatement()
public String getDeleteOldMessagesStatementWithPriority()
public String getLockCreateStatement()
public String getLeaseObtainStatement()
public String getCurrentDateTime()
public String getLeaseUpdateStatement()
public String getLeaseOwnerStatement()
public String getLockUpdateStatement()
public String getDestinationMessageCountStatement()
public String getFindNextMessagesStatement()
public String getFindNextMessagesByPriorityStatement()
public void setFindNextMessagesByPriorityStatement(String val)
public String getLastAckedDurableSubscriberMessageStatement()
public String getSelectDurablePriorityAckStatement()
public String getInsertDurablePriorityAckStatement()
public String getUpdateDurableLastAckStatement()
public String getUpdateDurableLastAckInTxStatement()
public String getUpdateDurableLastAckWithPriorityStatement()
public String getUpdateDurableLastAckWithPriorityInTxStatement()
public String getClearDurableLastAckInTxStatement()
public String getFindOpsPendingOutcomeStatement()
public String getFindAcksPendingOutcomeStatement()
public String getUpdateXidFlagStatement()
public String getClearXidFlagStatement()
public String getFullMessageTableName()
public String getFullAckTableName()
public String getFullLockTableName()
public String getContainerNameDataType()
public void setContainerNameDataType(String containerNameDataType)
containerNameDataType
- The containerNameDataType to set.public String getBinaryDataType()
public void setBinaryDataType(String messageDataType)
messageDataType
- The messageDataType to set.public String getMessageTableName()
public void setMessageTableName(String messageTableName)
messageTableName
- The messageTableName to set.public String getMsgIdDataType()
public void setMsgIdDataType(String msgIdDataType)
msgIdDataType
- The msgIdDataType to set.public String getSequenceDataType()
public void setSequenceDataType(String sequenceDataType)
sequenceDataType
- The sequenceDataType to set.public String getTablePrefix()
public void setTablePrefix(String tablePrefix)
tablePrefix
- The tablePrefix to set.public String getDurableSubAcksTableName()
public void setDurableSubAcksTableName(String durableSubAcksTableName)
durableSubAcksTableName
- The durableSubAcksTableName to set.public String getLockTableName()
public void setLockTableName(String lockTableName)
public String getLongDataType()
public void setLongDataType(String longDataType)
public String getStringIdDataType()
public void setStringIdDataType(String stringIdDataType)
public void setUseExternalMessageReferences(boolean useExternalMessageReferences)
public boolean isUseExternalMessageReferences()
public void setAddMessageStatement(String addMessageStatment)
public void setCreateDurableSubStatement(String createDurableSubStatment)
public void setCreateSchemaStatements(String[] createSchemaStatments)
public void setCreateLockSchemaStatements(String[] createLockSchemaStatments)
public void setDeleteOldMessagesStatementWithPriority(String deleteOldMessagesStatementWithPriority)
public void setDeleteSubscriptionStatement(String deleteSubscriptionStatment)
public void setDropSchemaStatements(String[] dropSchemaStatments)
public void setFindAllDestinationsStatement(String findAllDestinationsStatment)
public void setFindAllDurableSubMessagesStatement(String findAllDurableSubMessagesStatment)
public void setFindAllDurableSubsStatement(String findAllDurableSubsStatment)
public void setFindAllMessagesStatement(String findAllMessagesStatment)
public void setFindDurableSubStatement(String findDurableSubStatment)
public void setFindLastSequenceIdInAcksStatement(String findLastSequenceIdInAcks)
public void setFindLastSequenceIdInMsgsStatement(String findLastSequenceIdInMsgs)
public void setFindMessageSequenceIdStatement(String findMessageSequenceIdStatment)
public void setFindMessageStatement(String findMessageStatment)
public void setFindMessageByIdStatement(String findMessageByIdStatement)
public void setRemoveAllMessagesStatement(String removeAllMessagesStatment)
public void setRemoveAllSubscriptionsStatement(String removeAllSubscriptionsStatment)
public void setRemoveMessageStatment(String removeMessageStatement)
public void setUpdateLastPriorityAckRowOfDurableSubStatement(String updateLastPriorityAckRowOfDurableSubStatement)
public void setUpdateMessageStatement(String updateMessageStatment)
public boolean isUseLockCreateWhereClause()
public void setUseLockCreateWhereClause(boolean useLockCreateWhereClause)
public void setLockCreateStatement(String lockCreateStatement)
public void setLockUpdateStatement(String lockUpdateStatement)
public void setFindDurableSubMessagesStatement(String findDurableSubMessagesStatement)
findDurableSubMessagesStatement
- the
findDurableSubMessagesStatement to setpublic void setNextDurableSubscriberMessageStatement(String nextDurableSubscriberMessageStatement)
nextDurableSubscriberMessageStatement
- the nextDurableSubscriberMessageStatement to setpublic void setDurableSubscriberMessageCountStatement(String durableSubscriberMessageCountStatement)
durableSubscriberMessageCountStatement
- the durableSubscriberMessageCountStatement to setpublic void setDurableSubscriberMessageCountStatementWithPriority(String durableSubscriberMessageCountStatementWithPriority)
public void setFindNextMessagesStatement(String findNextMessagesStatement)
findNextMessagesStatement
- the findNextMessagesStatement to setpublic void setDestinationMessageCountStatement(String destinationMessageCountStatement)
destinationMessageCountStatement
- the destinationMessageCountStatement to setpublic void setLastAckedDurableSubscriberMessageStatement(String lastAckedDurableSubscriberMessageStatement)
lastAckedDurableSubscriberMessageStatement
- the lastAckedDurableSubscriberMessageStatement to setpublic void setLastProducerSequenceIdStatement(String lastProducerSequenceIdStatement)
public void setSelectDurablePriorityAckStatement(String selectDurablePriorityAckStatement)
public void setInsertDurablePriorityAckStatement(String insertDurablePriorityAckStatement)
public void setUpdateDurableLastAckStatement(String updateDurableLastAckStatement)
public void setUpdateXidFlagStatement(String updateXidFlagStatement)
public void setFindOpsPendingOutcomeStatement(String findOpsPendingOutcomeStatement)
public void setClearXidFlagStatement(String clearXidFlagStatement)
public void setUpdateDurableLastAckInTxStatement(String updateDurableLastAckInTxStatement)
public void setFindAcksPendingOutcomeStatement(String findAcksPendingOutcomeStatement)
public void setClearDurableLastAckInTxStatement(String clearDurableLastAckInTxStatement)
public void setUpdateDurableLastAckWithPriorityStatement(String updateDurableLastAckWithPriorityStatement)
public void setUpdateDurableLastAckWithPriorityInTxStatement(String updateDurableLastAckWithPriorityInTxStatement)
public void setFindXidByIdStatement(String findXidByIdStatement)
public void setLeaseObtainStatement(String leaseObtainStatement)
public void setCurrentDateTimeStatement(String currentDateTimeStatement)
public void setLeaseUpdateStatement(String leaseUpdateStatement)
public void setLeaseOwnerStatement(String leaseOwnerStatement)
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.