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 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 getFindAllMessagesStatement()
public String getFindAllMessageIdsStatement()
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 findAllDurableSubMessagesStatement()
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 getLockUpdateStatement()
public String getDestinationMessageCountStatement()
public String getFindNextMessagesStatement()
public String getFindNextMessagesByPriorityStatement()
public String getLastAckedDurableSubscriberMessageStatement()
public String getSelectDurablePriorityAckStatement()
public String getInsertDurablePriorityAckStatement()
public String getUpdateDurableLastAckStatement()
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 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)
Copyright © 2005–2017. All rights reserved.