org.activemq.store.jdbc.adapter
Class CachingStatementProvider

java.lang.Object
  org.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