public class Statements extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
binaryDataType |
protected java.lang.String |
containerNameDataType |
protected java.lang.String |
durableSubAcksTableName |
protected java.lang.String |
lockTableName |
protected java.lang.String |
longDataType |
protected java.lang.String |
messageTableName |
protected java.lang.String |
msgIdDataType |
protected java.lang.String |
sequenceDataType |
protected java.lang.String |
stringIdDataType |
protected boolean |
useExternalMessageReferences |
Constructor and Description |
---|
Statements() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
findAllDurableSubMessagesStatement() |
java.lang.String |
getAddMessageStatement() |
java.lang.String |
getBinaryDataType() |
java.lang.String |
getContainerNameDataType() |
java.lang.String |
getCreateDurableSubStatement() |
java.lang.String[] |
getCreateSchemaStatements() |
java.lang.String |
getDeleteOldMessagesStatementWithPriority() |
java.lang.String |
getDeleteSubscriptionStatement() |
java.lang.String |
getDestinationMessageCountStatement() |
java.lang.String |
getDropAckPKAlterStatementEnd() |
java.lang.String[] |
getDropSchemaStatements() |
java.lang.String |
getDurableSubAcksTableName() |
java.lang.String |
getDurableSubscriberMessageCountStatement() |
java.lang.String |
getDurableSubscriberMessageCountStatementWithPriority() |
java.lang.String |
getFindAllDestinationsStatement() |
java.lang.String |
getFindAllDurableSubMessagesStatement() |
java.lang.String |
getFindAllDurableSubsStatement() |
java.lang.String |
getFindAllMessageIdsStatement() |
java.lang.String |
getFindAllMessagesStatement() |
java.lang.String |
getFindDurableSubMessagesByPriorityStatement() |
java.lang.String |
getFindDurableSubMessagesStatement() |
java.lang.String |
getFindDurableSubStatement() |
java.lang.String |
getFindLastSequenceIdInAcksStatement() |
java.lang.String |
getFindLastSequenceIdInMsgsStatement() |
java.lang.String |
getFindMessageByIdStatement() |
java.lang.String |
getFindMessageSequenceIdStatement() |
java.lang.String |
getFindMessageStatement() |
java.lang.String |
getFindNextMessagesByPriorityStatement() |
java.lang.String |
getFindNextMessagesStatement() |
java.lang.String |
getFullAckTableName() |
java.lang.String |
getFullLockTableName() |
java.lang.String |
getFullMessageTableName() |
java.lang.String |
getInsertDurablePriorityAckStatement() |
java.lang.String |
getLastAckedDurableSubscriberMessageStatement() |
java.lang.String |
getLastProducerSequenceIdStatement() |
java.lang.String |
getLockCreateStatement() |
java.lang.String |
getLockTableName() |
java.lang.String |
getLockUpdateStatement() |
java.lang.String |
getLongDataType() |
java.lang.String |
getMessageTableName() |
java.lang.String |
getMsgIdDataType() |
java.lang.String |
getNextDurableSubscriberMessageStatement() |
java.lang.String |
getRemoveAllMessagesStatement() |
java.lang.String |
getRemoveAllSubscriptionsStatement() |
java.lang.String |
getRemoveMessageStatement() |
java.lang.String |
getSelectDurablePriorityAckStatement() |
java.lang.String |
getSequenceDataType() |
java.lang.String |
getStringIdDataType() |
java.lang.String |
getTablePrefix() |
java.lang.String |
getUpdateDurableLastAckStatement() |
java.lang.String |
getUpdateLastPriorityAckRowOfDurableSubStatement() |
java.lang.String |
getUpdateMessageStatement() |
boolean |
isUseExternalMessageReferences() |
boolean |
isUseLockCreateWhereClause() |
void |
setAddMessageStatement(java.lang.String addMessageStatment) |
void |
setBinaryDataType(java.lang.String messageDataType) |
void |
setContainerNameDataType(java.lang.String containerNameDataType) |
void |
setCreateDurableSubStatement(java.lang.String createDurableSubStatment) |
void |
setCreateSchemaStatements(java.lang.String[] createSchemaStatments) |
void |
setDeleteOldMessagesStatementWithPriority(java.lang.String deleteOldMessagesStatementWithPriority) |
void |
setDeleteSubscriptionStatement(java.lang.String deleteSubscriptionStatment) |
void |
setDestinationMessageCountStatement(java.lang.String destinationMessageCountStatement) |
void |
setDropAckPKAlterStatementEnd(java.lang.String dropAckPKAlterStatementEnd) |
void |
setDropSchemaStatements(java.lang.String[] dropSchemaStatments) |
void |
setDurableSubAcksTableName(java.lang.String durableSubAcksTableName) |
void |
setDurableSubscriberMessageCountStatement(java.lang.String durableSubscriberMessageCountStatement) |
void |
setDurableSubscriberMessageCountStatementWithPriority(java.lang.String durableSubscriberMessageCountStatementWithPriority) |
void |
setFindAllDestinationsStatement(java.lang.String findAllDestinationsStatment) |
void |
setFindAllDurableSubMessagesStatement(java.lang.String findAllDurableSubMessagesStatment) |
void |
setFindAllDurableSubsStatement(java.lang.String findAllDurableSubsStatment) |
void |
setFindAllMessagesStatement(java.lang.String findAllMessagesStatment) |
void |
setFindDurableSubMessagesStatement(java.lang.String findDurableSubMessagesStatement) |
void |
setFindDurableSubStatement(java.lang.String findDurableSubStatment) |
void |
setFindLastSequenceIdInAcksStatement(java.lang.String findLastSequenceIdInAcks) |
void |
setFindLastSequenceIdInMsgsStatement(java.lang.String findLastSequenceIdInMsgs) |
void |
setFindMessageByIdStatement(java.lang.String findMessageByIdStatement) |
void |
setFindMessageSequenceIdStatement(java.lang.String findMessageSequenceIdStatment) |
void |
setFindMessageStatement(java.lang.String findMessageStatment) |
void |
setFindNextMessagesStatement(java.lang.String findNextMessagesStatement) |
void |
setInsertDurablePriorityAckStatement(java.lang.String insertDurablePriorityAckStatement) |
void |
setLastAckedDurableSubscriberMessageStatement(java.lang.String lastAckedDurableSubscriberMessageStatement) |
void |
setLastProducerSequenceIdStatement(java.lang.String lastProducerSequenceIdStatement) |
void |
setLockCreateStatement(java.lang.String lockCreateStatement) |
void |
setLockTableName(java.lang.String lockTableName) |
void |
setLockUpdateStatement(java.lang.String lockUpdateStatement) |
void |
setLongDataType(java.lang.String longDataType) |
void |
setMessageTableName(java.lang.String messageTableName) |
void |
setMsgIdDataType(java.lang.String msgIdDataType) |
void |
setNextDurableSubscriberMessageStatement(java.lang.String nextDurableSubscriberMessageStatement) |
void |
setRemoveAllMessagesStatement(java.lang.String removeAllMessagesStatment) |
void |
setRemoveAllSubscriptionsStatement(java.lang.String removeAllSubscriptionsStatment) |
void |
setRemoveMessageStatment(java.lang.String removeMessageStatement) |
void |
setSelectDurablePriorityAckStatement(java.lang.String selectDurablePriorityAckStatement) |
void |
setSequenceDataType(java.lang.String sequenceDataType) |
void |
setStringIdDataType(java.lang.String stringIdDataType) |
void |
setTablePrefix(java.lang.String tablePrefix) |
void |
setUpdateDurableLastAckStatement(java.lang.String updateDurableLastAckStatement) |
void |
setUpdateLastPriorityAckRowOfDurableSubStatement(java.lang.String updateLastPriorityAckRowOfDurableSubStatement) |
void |
setUpdateMessageStatement(java.lang.String updateMessageStatment) |
void |
setUseExternalMessageReferences(boolean useExternalMessageReferences) |
void |
setUseLockCreateWhereClause(boolean useLockCreateWhereClause) |
protected java.lang.String messageTableName
protected java.lang.String durableSubAcksTableName
protected java.lang.String lockTableName
protected java.lang.String binaryDataType
protected java.lang.String containerNameDataType
protected java.lang.String msgIdDataType
protected java.lang.String sequenceDataType
protected java.lang.String longDataType
protected java.lang.String stringIdDataType
protected boolean useExternalMessageReferences
public Statements()
public java.lang.String[] getCreateSchemaStatements()
public java.lang.String getDropAckPKAlterStatementEnd()
public void setDropAckPKAlterStatementEnd(java.lang.String dropAckPKAlterStatementEnd)
public java.lang.String[] getDropSchemaStatements()
public java.lang.String getAddMessageStatement()
public java.lang.String getUpdateMessageStatement()
public java.lang.String getRemoveMessageStatement()
public java.lang.String getFindMessageSequenceIdStatement()
public java.lang.String getFindMessageStatement()
public java.lang.String getFindMessageByIdStatement()
public java.lang.String getFindAllMessagesStatement()
public java.lang.String getFindAllMessageIdsStatement()
public java.lang.String getFindLastSequenceIdInMsgsStatement()
public java.lang.String getLastProducerSequenceIdStatement()
public java.lang.String getFindLastSequenceIdInAcksStatement()
public java.lang.String getCreateDurableSubStatement()
public java.lang.String getFindDurableSubStatement()
public java.lang.String getFindAllDurableSubsStatement()
public java.lang.String getUpdateLastPriorityAckRowOfDurableSubStatement()
public java.lang.String getDeleteSubscriptionStatement()
public java.lang.String getFindAllDurableSubMessagesStatement()
public java.lang.String getFindDurableSubMessagesStatement()
public java.lang.String getFindDurableSubMessagesByPriorityStatement()
public java.lang.String findAllDurableSubMessagesStatement()
public java.lang.String getNextDurableSubscriberMessageStatement()
public java.lang.String getDurableSubscriberMessageCountStatement()
public java.lang.String getDurableSubscriberMessageCountStatementWithPriority()
public java.lang.String getFindAllDestinationsStatement()
public java.lang.String getRemoveAllMessagesStatement()
public java.lang.String getRemoveAllSubscriptionsStatement()
public java.lang.String getDeleteOldMessagesStatementWithPriority()
public java.lang.String getLockCreateStatement()
public java.lang.String getLockUpdateStatement()
public java.lang.String getDestinationMessageCountStatement()
public java.lang.String getFindNextMessagesStatement()
public java.lang.String getFindNextMessagesByPriorityStatement()
public java.lang.String getLastAckedDurableSubscriberMessageStatement()
public java.lang.String getSelectDurablePriorityAckStatement()
public java.lang.String getInsertDurablePriorityAckStatement()
public java.lang.String getUpdateDurableLastAckStatement()
public java.lang.String getFullMessageTableName()
public java.lang.String getFullAckTableName()
public java.lang.String getFullLockTableName()
public java.lang.String getContainerNameDataType()
public void setContainerNameDataType(java.lang.String containerNameDataType)
containerNameDataType
- The containerNameDataType to set.public java.lang.String getBinaryDataType()
public void setBinaryDataType(java.lang.String messageDataType)
messageDataType
- The messageDataType to set.public java.lang.String getMessageTableName()
public void setMessageTableName(java.lang.String messageTableName)
messageTableName
- The messageTableName to set.public java.lang.String getMsgIdDataType()
public void setMsgIdDataType(java.lang.String msgIdDataType)
msgIdDataType
- The msgIdDataType to set.public java.lang.String getSequenceDataType()
public void setSequenceDataType(java.lang.String sequenceDataType)
sequenceDataType
- The sequenceDataType to set.public java.lang.String getTablePrefix()
public void setTablePrefix(java.lang.String tablePrefix)
tablePrefix
- The tablePrefix to set.public java.lang.String getDurableSubAcksTableName()
public void setDurableSubAcksTableName(java.lang.String durableSubAcksTableName)
durableSubAcksTableName
- The durableSubAcksTableName to set.public java.lang.String getLockTableName()
public void setLockTableName(java.lang.String lockTableName)
public java.lang.String getLongDataType()
public void setLongDataType(java.lang.String longDataType)
public java.lang.String getStringIdDataType()
public void setStringIdDataType(java.lang.String stringIdDataType)
public void setUseExternalMessageReferences(boolean useExternalMessageReferences)
public boolean isUseExternalMessageReferences()
public void setAddMessageStatement(java.lang.String addMessageStatment)
public void setCreateDurableSubStatement(java.lang.String createDurableSubStatment)
public void setCreateSchemaStatements(java.lang.String[] createSchemaStatments)
public void setDeleteOldMessagesStatementWithPriority(java.lang.String deleteOldMessagesStatementWithPriority)
public void setDeleteSubscriptionStatement(java.lang.String deleteSubscriptionStatment)
public void setDropSchemaStatements(java.lang.String[] dropSchemaStatments)
public void setFindAllDestinationsStatement(java.lang.String findAllDestinationsStatment)
public void setFindAllDurableSubMessagesStatement(java.lang.String findAllDurableSubMessagesStatment)
public void setFindAllDurableSubsStatement(java.lang.String findAllDurableSubsStatment)
public void setFindAllMessagesStatement(java.lang.String findAllMessagesStatment)
public void setFindDurableSubStatement(java.lang.String findDurableSubStatment)
public void setFindLastSequenceIdInAcksStatement(java.lang.String findLastSequenceIdInAcks)
public void setFindLastSequenceIdInMsgsStatement(java.lang.String findLastSequenceIdInMsgs)
public void setFindMessageSequenceIdStatement(java.lang.String findMessageSequenceIdStatment)
public void setFindMessageStatement(java.lang.String findMessageStatment)
public void setFindMessageByIdStatement(java.lang.String findMessageByIdStatement)
public void setRemoveAllMessagesStatement(java.lang.String removeAllMessagesStatment)
public void setRemoveAllSubscriptionsStatement(java.lang.String removeAllSubscriptionsStatment)
public void setRemoveMessageStatment(java.lang.String removeMessageStatement)
public void setUpdateLastPriorityAckRowOfDurableSubStatement(java.lang.String updateLastPriorityAckRowOfDurableSubStatement)
public void setUpdateMessageStatement(java.lang.String updateMessageStatment)
public boolean isUseLockCreateWhereClause()
public void setUseLockCreateWhereClause(boolean useLockCreateWhereClause)
public void setLockCreateStatement(java.lang.String lockCreateStatement)
public void setLockUpdateStatement(java.lang.String lockUpdateStatement)
public void setFindDurableSubMessagesStatement(java.lang.String findDurableSubMessagesStatement)
findDurableSubMessagesStatement
- the
findDurableSubMessagesStatement to setpublic void setNextDurableSubscriberMessageStatement(java.lang.String nextDurableSubscriberMessageStatement)
nextDurableSubscriberMessageStatement
- the nextDurableSubscriberMessageStatement to setpublic void setDurableSubscriberMessageCountStatement(java.lang.String durableSubscriberMessageCountStatement)
durableSubscriberMessageCountStatement
- the durableSubscriberMessageCountStatement to setpublic void setDurableSubscriberMessageCountStatementWithPriority(java.lang.String durableSubscriberMessageCountStatementWithPriority)
public void setFindNextMessagesStatement(java.lang.String findNextMessagesStatement)
findNextMessagesStatement
- the findNextMessagesStatement to setpublic void setDestinationMessageCountStatement(java.lang.String destinationMessageCountStatement)
destinationMessageCountStatement
- the destinationMessageCountStatement to setpublic void setLastAckedDurableSubscriberMessageStatement(java.lang.String lastAckedDurableSubscriberMessageStatement)
lastAckedDurableSubscriberMessageStatement
- the lastAckedDurableSubscriberMessageStatement to setpublic void setLastProducerSequenceIdStatement(java.lang.String lastProducerSequenceIdStatement)
public void setSelectDurablePriorityAckStatement(java.lang.String selectDurablePriorityAckStatement)
public void setInsertDurablePriorityAckStatement(java.lang.String insertDurablePriorityAckStatement)
public void setUpdateDurableLastAckStatement(java.lang.String updateDurableLastAckStatement)
Copyright © 2005-2017. All Rights Reserved.