org.activemq.store.jdbc.adapter
Class CachingStatementProvider

java.lang.Object
  extended byorg.activemq.store.jdbc.adapter.CachingStatementProvider
All Implemented Interfaces:
StatementProvider

public class CachingStatementProvider
extends Object
implements StatementProvider

A StatementProvider filter that caches the responses of the filtered StatementProvider.

Version:
$Revision: 1.1 $

Constructor Summary
CachingStatementProvider(StatementProvider statementProvider)
           
 
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()
           
 StatementProvider getNext()
           
 String getRemoveAllMessagesStatment()
           
 String getRemoveAllSubscriptionsStatment()
           
 String getRemoveMessageStatment()
           
 String getRemoveXidStatment()
           
 String getSetDeadLetterFlagStatement()
           
 String getTablePrefix()
           
 String getUpdateDurableSubStatment()
           
 String getUpdateLastAckOfDurableSub()
           
 String getUpdateMessageStatment()
           
 void setTablePrefix(String tablePrefix)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CachingStatementProvider

public CachingStatementProvider(StatementProvider statementProvider)
Method Detail

getNext

public StatementProvider getNext()

getAddMessageStatment

public String getAddMessageStatment()
Specified by:
getAddMessageStatment in interface StatementProvider

getAddXidStatment

public String getAddXidStatment()
Specified by:
getAddXidStatment in interface StatementProvider

getCreateSchemaStatments

public String[] getCreateSchemaStatments()
Specified by:
getCreateSchemaStatments in interface StatementProvider

getDropSchemaStatments

public String[] getDropSchemaStatments()
Specified by:
getDropSchemaStatments in interface StatementProvider

getFindAllMessagesStatment

public String getFindAllMessagesStatment()
Specified by:
getFindAllMessagesStatment in interface StatementProvider

getFindAllXidStatment

public String getFindAllXidStatment()
Specified by:
getFindAllXidStatment in interface StatementProvider

getFindLastSequenceIdInMsgs

public String getFindLastSequenceIdInMsgs()
Specified by:
getFindLastSequenceIdInMsgs in interface StatementProvider

getFindLastSequenceIdInAcks

public String getFindLastSequenceIdInAcks()
Specified by:
getFindLastSequenceIdInAcks in interface StatementProvider

getFindMessageStatment

public String getFindMessageStatment()
Specified by:
getFindMessageStatment in interface StatementProvider

getFindMessageAttributesStatment

public String getFindMessageAttributesStatment()
Specified by:
getFindMessageAttributesStatment in interface StatementProvider

getFindMessageAttributesForUpdateStatment

public String getFindMessageAttributesForUpdateStatment()
Specified by:
getFindMessageAttributesForUpdateStatment in interface StatementProvider

getRemoveMessageStatment

public String getRemoveMessageStatment()
Specified by:
getRemoveMessageStatment in interface StatementProvider
Returns:

getRemoveXidStatment

public String getRemoveXidStatment()
Specified by:
getRemoveXidStatment in interface StatementProvider

getUpdateMessageStatment

public String getUpdateMessageStatment()
Specified by:
getUpdateMessageStatment in interface StatementProvider

getCreateDurableSubStatment

public String getCreateDurableSubStatment()
Specified by:
getCreateDurableSubStatment in interface StatementProvider

getUpdateDurableSubStatment

public String getUpdateDurableSubStatment()
Specified by:
getUpdateDurableSubStatment in interface StatementProvider

getFindDurableSubStatment

public String getFindDurableSubStatment()
Specified by:
getFindDurableSubStatment in interface StatementProvider

getFindAllDurableSubMessagesStatment

public String getFindAllDurableSubMessagesStatment()
Specified by:
getFindAllDurableSubMessagesStatment in interface StatementProvider

getUpdateLastAckOfDurableSub

public String getUpdateLastAckOfDurableSub()
Specified by:
getUpdateLastAckOfDurableSub in interface StatementProvider

getFindMessageSequenceIdStatment

public String getFindMessageSequenceIdStatment()
Specified by:
getFindMessageSequenceIdStatment in interface StatementProvider

getRemoveAllMessagesStatment

public String getRemoveAllMessagesStatment()
Specified by:
getRemoveAllMessagesStatment in interface StatementProvider

getRemoveAllSubscriptionsStatment

public String getRemoveAllSubscriptionsStatment()
Specified by:
getRemoveAllSubscriptionsStatment in interface StatementProvider

getDeleteSubscriptionStatment

public String getDeleteSubscriptionStatment()
Specified by:
getDeleteSubscriptionStatment in interface StatementProvider

getDeleteOldMessagesStatment

public String getDeleteOldMessagesStatment()
Specified by:
getDeleteOldMessagesStatment in interface StatementProvider

getFindExpiredMessagesStatment

public String getFindExpiredMessagesStatment()
Specified by:
getFindExpiredMessagesStatment in interface StatementProvider

getDeleteMessageStatement

public String getDeleteMessageStatement()
Specified by:
getDeleteMessageStatement in interface StatementProvider

getSetDeadLetterFlagStatement

public String getSetDeadLetterFlagStatement()
Specified by:
getSetDeadLetterFlagStatement in interface StatementProvider

setTablePrefix

public void setTablePrefix(String tablePrefix)
Specified by:
setTablePrefix in interface StatementProvider

getTablePrefix

public String getTablePrefix()
Specified by:
getTablePrefix in interface StatementProvider


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