org.activemq.store.jdbc
Interface StatementProvider

All Known Implementing Classes:
CachingStatementProvider, DefaultStatementProvider

public interface StatementProvider

Generates the SQL statements that are used by the JDBCAdapter.

Version:
$Revision: 1.1 $

Method Summary
 String getAddMessageStatment()
           
 String getAddXidStatment()
           
 String getCreateDurableSubStatment()
           
 String[] getCreateSchemaStatments()
           
 String getDeleteMessageStatement()
           
 String getDeleteOldMessagesStatment()
           
 String getDeleteSubscriptionStatment()
           
 String[] getDropSchemaStatments()
           
 String getFindAllDurableSubMessagesStatment()
           
 String getFindAllMessagesStatment()
           
 String getFindAllXidStatment()
           
 String getFindDurableSubStatment()
           
 String getFindExpiredMessagesStatment()
           
 String getFindLastSequenceIdInAcks()
           
 String getFindLastSequenceIdInMsgs()
           
 String getFindMessageAttributesForUpdateStatment()
           
 String getFindMessageAttributesStatment()
           
 String getFindMessageSequenceIdStatment()
           
 String getFindMessageStatment()
           
 String getRemoveAllMessagesStatment()
           
 String getRemoveAllSubscriptionsStatment()
           
 String getRemoveMessageStatment()
           
 String getRemoveXidStatment()
           
 String getSetDeadLetterFlagStatement()
           
 String getTablePrefix()
           
 String getUpdateDurableSubStatment()
           
 String getUpdateLastAckOfDurableSub()
           
 String getUpdateMessageStatment()
           
 void setTablePrefix(String tablePrefix)
           
 

Method Detail

getCreateSchemaStatments

public String[] getCreateSchemaStatments()

getDropSchemaStatments

public String[] getDropSchemaStatments()

getAddMessageStatment

public String getAddMessageStatment()

getUpdateMessageStatment

public String getUpdateMessageStatment()

getRemoveMessageStatment

public String getRemoveMessageStatment()

getFindMessageSequenceIdStatment

public String getFindMessageSequenceIdStatment()

getFindMessageStatment

public String getFindMessageStatment()

getFindMessageAttributesStatment

public String getFindMessageAttributesStatment()

getFindMessageAttributesForUpdateStatment

public String getFindMessageAttributesForUpdateStatment()

getFindAllMessagesStatment

public String getFindAllMessagesStatment()

getFindLastSequenceIdInMsgs

public String getFindLastSequenceIdInMsgs()

getFindLastSequenceIdInAcks

public String getFindLastSequenceIdInAcks()

getAddXidStatment

public String getAddXidStatment()

getRemoveXidStatment

public String getRemoveXidStatment()

getFindAllXidStatment

public String getFindAllXidStatment()

getCreateDurableSubStatment

public String getCreateDurableSubStatment()

getUpdateDurableSubStatment

public String getUpdateDurableSubStatment()

getFindDurableSubStatment

public String getFindDurableSubStatment()

getUpdateLastAckOfDurableSub

public String getUpdateLastAckOfDurableSub()

getFindAllDurableSubMessagesStatment

public String getFindAllDurableSubMessagesStatment()

getRemoveAllMessagesStatment

public String getRemoveAllMessagesStatment()

getRemoveAllSubscriptionsStatment

public String getRemoveAllSubscriptionsStatment()

getDeleteSubscriptionStatment

public String getDeleteSubscriptionStatment()

getDeleteOldMessagesStatment

public String getDeleteOldMessagesStatment()

getFindExpiredMessagesStatment

public String getFindExpiredMessagesStatment()

getDeleteMessageStatement

public String getDeleteMessageStatement()

getSetDeadLetterFlagStatement

public String getSetDeadLetterFlagStatement()

setTablePrefix

public void setTablePrefix(String tablePrefix)

getTablePrefix

public String getTablePrefix()


Copyright © 2004-2007 Protique, Ltd.. All Rights Reserved.