org.apache.activemq.store.jdbc
Class Statements

java.lang.Object
  extended by org.apache.activemq.store.jdbc.Statements

public class Statements
extends Object

Version:
$Revision: 1.4 $

Field Summary
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 Summary
Statements()
           
 
Method Summary
 String findAllDurableSubMessagesStatement()
           
 String getAddMessageStatement()
           
 String getBinaryDataType()
           
 String getContainerNameDataType()
           
 String getCreateDurableSubStatement()
           
 String[] getCreateSchemaStatements()
           
 String getDeleteOldMessagesStatement()
           
 String getDeleteSubscriptionStatement()
           
 String getDestinationMessageCountStatement()
           
 String[] getDropSchemaStatements()
           
 String getDurableSubAcksTableName()
           
 String getDurableSubscriberMessageCountStatement()
           
 String getFindAllDestinationsStatement()
           
 String getFindAllDurableSubMessagesStatement()
           
 String getFindAllDurableSubsStatement()
           
 String getFindAllMessageIdsStatement()
           
 String getFindAllMessagesStatement()
           
 String getFindDurableSubMessagesStatement()
           
 String getFindDurableSubStatement()
           
 String getFindLastSequenceIdInAcksStatement()
           
 String getFindLastSequenceIdInMsgsStatement()
           
 String getFindMessageByIdStatement()
           
 String getFindMessageSequenceIdStatement()
           
 String getFindMessageStatement()
           
 String getFindNextMessagesStatement()
           
 String getFullAckTableName()
           
 String getFullLockTableName()
           
 String getFullMessageTableName()
           
 String getLastAckedDurableSubscriberMessageStatement()
           
 String getLockCreateStatement()
           
 String getLockTableName()
           
 String getLockUpdateStatement()
           
 String getLongDataType()
           
 String getMessageTableName()
           
 String getMsgIdDataType()
           
 String getNextDurableSubscriberMessageStatement()
           
 String getRemoveAllMessagesStatement()
           
 String getRemoveAllSubscriptionsStatement()
           
 String getRemoveMessageStatment()
           
 String getSequenceDataType()
           
 String getStringIdDataType()
           
 String getTablePrefix()
           
 String getUpdateLastAckOfDurableSubStatement()
           
 String getUpdateMessageStatement()
           
 boolean isUseExternalMessageReferences()
           
 boolean isUseLockCreateWhereClause()
           
 void setAddMessageStatement(String addMessageStatment)
           
 void setBinaryDataType(String messageDataType)
           
 void setContainerNameDataType(String containerNameDataType)
           
 void setCreateDurableSubStatement(String createDurableSubStatment)
           
 void setCreateSchemaStatements(String[] createSchemaStatments)
           
 void setDeleteOldMessagesStatement(String deleteOldMessagesStatment)
           
 void setDeleteSubscriptionStatement(String deleteSubscriptionStatment)
           
 void setDestinationMessageCountStatement(String destinationMessageCountStatement)
           
 void setDropSchemaStatements(String[] dropSchemaStatments)
           
 void setDurableSubAcksTableName(String durableSubAcksTableName)
           
 void setDurableSubscriberMessageCountStatement(String durableSubscriberMessageCountStatement)
           
 void setFindAllDestinationsStatement(String findAllDestinationsStatment)
           
 void setFindAllDurableSubMessagesStatement(String findAllDurableSubMessagesStatment)
           
 void setFindAllDurableSubsStatement(String findAllDurableSubsStatment)
           
 void setFindAllMessagesStatement(String findAllMessagesStatment)
           
 void setFindDurableSubMessagesStatement(String findDurableSubMessagesStatement)
           
 void setFindDurableSubStatement(String findDurableSubStatment)
           
 void setFindLastSequenceIdInAcksStatement(String findLastSequenceIdInAcks)
           
 void setFindLastSequenceIdInMsgsStatement(String findLastSequenceIdInMsgs)
           
 void setFindMessageSequenceIdStatement(String findMessageSequenceIdStatment)
           
 void setFindMessageStatement(String findMessageStatment)
           
 void setFindNextMessagesStatement(String findNextMessagesStatement)
           
 void setLastAckedDurableSubscriberMessageStatement(String lastAckedDurableSubscriberMessageStatement)
           
 void setLockCreateStatement(String lockCreateStatement)
           
 void setLockTableName(String lockTableName)
           
 void setLockUpdateStatement(String lockUpdateStatement)
           
 void setLongDataType(String longDataType)
           
 void setMessageTableName(String messageTableName)
           
 void setMsgIdDataType(String msgIdDataType)
           
 void setNextDurableSubscriberMessageStatement(String nextDurableSubscriberMessageStatement)
           
 void setRemoveAllMessagesStatement(String removeAllMessagesStatment)
           
 void setRemoveAllSubscriptionsStatement(String removeAllSubscriptionsStatment)
           
 void setRemoveMessageStatment(String removeMessageStatment)
           
 void setSequenceDataType(String sequenceDataType)
           
 void setStringIdDataType(String stringIdDataType)
           
 void setTablePrefix(String tablePrefix)
           
 void setUpdateLastAckOfDurableSubStatement(String updateLastAckOfDurableSub)
           
 void setUpdateMessageStatement(String updateMessageStatment)
           
 void setUseExternalMessageReferences(boolean useExternalMessageReferences)
           
 void setUseLockCreateWhereClause(boolean useLockCreateWhereClause)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

Statements

public Statements()
Method Detail

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()

getFindMessageByIdStatement

public String getFindMessageByIdStatement()

getFindAllMessagesStatement

public String getFindAllMessagesStatement()

getFindAllMessageIdsStatement

public String getFindAllMessageIdsStatement()

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

getFindAllDestinationsStatement

public String getFindAllDestinationsStatement()

getRemoveAllMessagesStatement

public String getRemoveAllMessagesStatement()

getRemoveAllSubscriptionsStatement

public String getRemoveAllSubscriptionsStatement()

getDeleteOldMessagesStatement

public String getDeleteOldMessagesStatement()

getLockCreateStatement

public String getLockCreateStatement()

getLockUpdateStatement

public String getLockUpdateStatement()

getDestinationMessageCountStatement

public String getDestinationMessageCountStatement()
Returns:
the destinationMessageCountStatement

getFindNextMessagesStatement

public String getFindNextMessagesStatement()
Returns:
the findNextMessagesStatement

getLastAckedDurableSubscriberMessageStatement

public String getLastAckedDurableSubscriberMessageStatement()
Returns:
the lastAckedDurableSubscriberMessageStatement

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

setFindNextMessagesStatement

public void setFindNextMessagesStatement(String findNextMessagesStatement)
Parameters:
findNextMessagesStatement - the findNextMessagesStatement to set

setDestinationMessageCountStatement

public void setDestinationMessageCountStatement(String destinationMessageCountStatement)
Parameters:
destinationMessageCountStatement - the destinationMessageCountStatement to set

setLastAckedDurableSubscriberMessageStatement

public void setLastAckedDurableSubscriberMessageStatement(String lastAckedDurableSubscriberMessageStatement)
Parameters:
lastAckedDurableSubscriberMessageStatement - the lastAckedDurableSubscriberMessageStatement to set


Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.