Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep
Overview  Package   Class  Use  Deprecated  Index 
Home >> All >> org >> activemq >> store >> jdbc >> [ adapter overview ]  PREV CLASS  NEXT CLASS
SUMMARY: JavaDoc of org.activemq.store.jdbc.adapter.CachingStatementProvider JAVADOC | Sourc code of org.activemq.store.jdbc.adapter.CachingStatementProvider SOURCE | Download org.activemq.store.jdbc.adapter.CachingStatementProvider DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.activemq.store.jdbc.adapter
Class CachingStatementProvider  view CachingStatementProvider download CachingStatementProvider.java

java.lang.Object
  extended byorg.activemq.store.jdbc.adapter.CachingStatementProvider
All Implemented Interfaces:
org.activemq.store.jdbc.StatementProvider
public class CachingStatementProvider
extends java.lang.Object
implements org.activemq.store.jdbc.StatementProvider

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

Version:
$Revision: 1.1 $

Field Summary
private  java.lang.String addMessageStatment
           
private  java.lang.String addXidStatment
           
private  java.lang.String createDurableSubStatment
           
private  java.lang.String[] createSchemaStatments
           
private  java.lang.String deleteMessageStatement
           
private  java.lang.String deleteOldMessagesStatment
           
private  java.lang.String deleteSubscriptionStatment
           
private  java.lang.String[] dropSchemaStatments
           
private  java.lang.String findAllDurableSubMessagesStatment
           
private  java.lang.String findAllMessagesStatment
           
private  java.lang.String findAllXidStatment
           
private  java.lang.String findDurableSubStatment
           
private  java.lang.String findExpiredMessagesStatement
           
private  java.lang.String findLastSequenceIdInAcks
           
private  java.lang.String findLastSequenceIdInMsgs
           
private  java.lang.String findMessageAttributesForUpdateStatment
           
private  java.lang.String findMessageAttributesStatment
           
private  java.lang.String findMessageSequenceIdStatment
           
private  java.lang.String findMessageStatment
           
private  java.lang.String removeAllMessagesStatment
           
private  java.lang.String removeAllSubscriptionsStatment
           
private  java.lang.String removeMessageStatment
           
private  java.lang.String removeXidStatment
           
private  java.lang.String setDeadLetterFlagStatement
           
private  org.activemq.store.jdbc.StatementProvider statementProvider
           
private  java.lang.String updateDurableSubStatment
           
private  java.lang.String updateLastAckOfDurableSub
           
private  java.lang.String updateMessageStatment
           
 
Constructor Summary
CachingStatementProvider(org.activemq.store.jdbc.StatementProvider statementProvider)
           
 
Method Summary
 java.lang.String getAddMessageStatment()
           
 java.lang.String getAddXidStatment()
           
 java.lang.String getCreateDurableSubStatment()
           
 java.lang.String[] getCreateSchemaStatments()
           
 java.lang.String getDeleteMessageStatement()
           
 java.lang.String getDeleteOldMessagesStatment()
           
 java.lang.String getDeleteSubscriptionStatment()
           
 java.lang.String[] getDropSchemaStatments()
           
 java.lang.String getFindAllDurableSubMessagesStatment()
           
 java.lang.String getFindAllMessagesStatment()
           
 java.lang.String getFindAllXidStatment()
           
 java.lang.String getFindDurableSubStatment()
           
 java.lang.String getFindExpiredMessagesStatment()
           
 java.lang.String getFindLastSequenceIdInAcks()
           
 java.lang.String getFindLastSequenceIdInMsgs()
           
 java.lang.String getFindMessageAttributesForUpdateStatment()
           
 java.lang.String getFindMessageAttributesStatment()
           
 java.lang.String getFindMessageSequenceIdStatment()
           
 java.lang.String getFindMessageStatment()
           
 org.activemq.store.jdbc.StatementProvider getNext()
           
 java.lang.String getRemoveAllMessagesStatment()
           
 java.lang.String getRemoveAllSubscriptionsStatment()
           
 java.lang.String getRemoveMessageStatment()
           
 java.lang.String getRemoveXidStatment()
           
 java.lang.String getSetDeadLetterFlagStatement()
           
 java.lang.String getTablePrefix()
           
 java.lang.String getUpdateDurableSubStatment()
           
 java.lang.String getUpdateLastAckOfDurableSub()
           
 java.lang.String getUpdateMessageStatment()
           
 void setTablePrefix(java.lang.String tablePrefix)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

statementProvider

private final org.activemq.store.jdbc.StatementProvider statementProvider

addMessageStatment

private java.lang.String addMessageStatment

addXidStatment

private java.lang.String addXidStatment

createSchemaStatments

private java.lang.String[] createSchemaStatments

dropSchemaStatments

private java.lang.String[] dropSchemaStatments

findAllMessagesStatment

private java.lang.String findAllMessagesStatment

findAllXidStatment

private java.lang.String findAllXidStatment

findLastSequenceIdInMsgs

private java.lang.String findLastSequenceIdInMsgs

findMessageStatment

private java.lang.String findMessageStatment

findMessageAttributesStatment

private java.lang.String findMessageAttributesStatment

findMessageAttributesForUpdateStatment

private java.lang.String findMessageAttributesForUpdateStatment

removeMessageStatment

private java.lang.String removeMessageStatment

removeXidStatment

private java.lang.String removeXidStatment

updateMessageStatment

private java.lang.String updateMessageStatment

createDurableSubStatment

private java.lang.String createDurableSubStatment

updateDurableSubStatment

private java.lang.String updateDurableSubStatment

findDurableSubStatment

private java.lang.String findDurableSubStatment

findAllDurableSubMessagesStatment

private java.lang.String findAllDurableSubMessagesStatment

updateLastAckOfDurableSub

private java.lang.String updateLastAckOfDurableSub

findMessageSequenceIdStatment

private java.lang.String findMessageSequenceIdStatment

removeAllMessagesStatment

private java.lang.String removeAllMessagesStatment

removeAllSubscriptionsStatment

private java.lang.String removeAllSubscriptionsStatment

deleteSubscriptionStatment

private java.lang.String deleteSubscriptionStatment

deleteOldMessagesStatment

private java.lang.String deleteOldMessagesStatment

findExpiredMessagesStatement

private java.lang.String findExpiredMessagesStatement

deleteMessageStatement

private java.lang.String deleteMessageStatement

findLastSequenceIdInAcks

private java.lang.String findLastSequenceIdInAcks

setDeadLetterFlagStatement

private java.lang.String setDeadLetterFlagStatement
Constructor Detail

CachingStatementProvider

public CachingStatementProvider(org.activemq.store.jdbc.StatementProvider statementProvider)
Method Detail

getNext

public org.activemq.store.jdbc.StatementProvider getNext()

getAddMessageStatment

public java.lang.String getAddMessageStatment()
Specified by:
getAddMessageStatment in interface org.activemq.store.jdbc.StatementProvider

getAddXidStatment

public java.lang.String getAddXidStatment()
Specified by:
getAddXidStatment in interface org.activemq.store.jdbc.StatementProvider

getCreateSchemaStatments

public java.lang.String[] getCreateSchemaStatments()
Specified by:
getCreateSchemaStatments in interface org.activemq.store.jdbc.StatementProvider

getDropSchemaStatments

public java.lang.String[] getDropSchemaStatments()
Specified by:
getDropSchemaStatments in interface org.activemq.store.jdbc.StatementProvider

getFindAllMessagesStatment

public java.lang.String getFindAllMessagesStatment()
Specified by:
getFindAllMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

getFindAllXidStatment

public java.lang.String getFindAllXidStatment()
Specified by:
getFindAllXidStatment in interface org.activemq.store.jdbc.StatementProvider

getFindLastSequenceIdInMsgs

public java.lang.String getFindLastSequenceIdInMsgs()
Specified by:
getFindLastSequenceIdInMsgs in interface org.activemq.store.jdbc.StatementProvider

getFindLastSequenceIdInAcks

public java.lang.String getFindLastSequenceIdInAcks()
Specified by:
getFindLastSequenceIdInAcks in interface org.activemq.store.jdbc.StatementProvider

getFindMessageStatment

public java.lang.String getFindMessageStatment()
Specified by:
getFindMessageStatment in interface org.activemq.store.jdbc.StatementProvider

getFindMessageAttributesStatment

public java.lang.String getFindMessageAttributesStatment()
Specified by:
getFindMessageAttributesStatment in interface org.activemq.store.jdbc.StatementProvider

getFindMessageAttributesForUpdateStatment

public java.lang.String getFindMessageAttributesForUpdateStatment()
Specified by:
getFindMessageAttributesForUpdateStatment in interface org.activemq.store.jdbc.StatementProvider

getRemoveMessageStatment

public java.lang.String getRemoveMessageStatment()
Specified by:
getRemoveMessageStatment in interface org.activemq.store.jdbc.StatementProvider

getRemoveXidStatment

public java.lang.String getRemoveXidStatment()
Specified by:
getRemoveXidStatment in interface org.activemq.store.jdbc.StatementProvider

getUpdateMessageStatment

public java.lang.String getUpdateMessageStatment()
Specified by:
getUpdateMessageStatment in interface org.activemq.store.jdbc.StatementProvider

getCreateDurableSubStatment

public java.lang.String getCreateDurableSubStatment()
Specified by:
getCreateDurableSubStatment in interface org.activemq.store.jdbc.StatementProvider

getUpdateDurableSubStatment

public java.lang.String getUpdateDurableSubStatment()
Specified by:
getUpdateDurableSubStatment in interface org.activemq.store.jdbc.StatementProvider

getFindDurableSubStatment

public java.lang.String getFindDurableSubStatment()
Specified by:
getFindDurableSubStatment in interface org.activemq.store.jdbc.StatementProvider

getFindAllDurableSubMessagesStatment

public java.lang.String getFindAllDurableSubMessagesStatment()
Specified by:
getFindAllDurableSubMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

getUpdateLastAckOfDurableSub

public java.lang.String getUpdateLastAckOfDurableSub()
Specified by:
getUpdateLastAckOfDurableSub in interface org.activemq.store.jdbc.StatementProvider

getFindMessageSequenceIdStatment

public java.lang.String getFindMessageSequenceIdStatment()
Specified by:
getFindMessageSequenceIdStatment in interface org.activemq.store.jdbc.StatementProvider

getRemoveAllMessagesStatment

public java.lang.String getRemoveAllMessagesStatment()
Specified by:
getRemoveAllMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

getRemoveAllSubscriptionsStatment

public java.lang.String getRemoveAllSubscriptionsStatment()
Specified by:
getRemoveAllSubscriptionsStatment in interface org.activemq.store.jdbc.StatementProvider

getDeleteSubscriptionStatment

public java.lang.String getDeleteSubscriptionStatment()
Specified by:
getDeleteSubscriptionStatment in interface org.activemq.store.jdbc.StatementProvider

getDeleteOldMessagesStatment

public java.lang.String getDeleteOldMessagesStatment()
Specified by:
getDeleteOldMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

getFindExpiredMessagesStatment

public java.lang.String getFindExpiredMessagesStatment()
Specified by:
getFindExpiredMessagesStatment in interface org.activemq.store.jdbc.StatementProvider

getDeleteMessageStatement

public java.lang.String getDeleteMessageStatement()
Specified by:
getDeleteMessageStatement in interface org.activemq.store.jdbc.StatementProvider

getSetDeadLetterFlagStatement

public java.lang.String getSetDeadLetterFlagStatement()
Specified by:
getSetDeadLetterFlagStatement in interface org.activemq.store.jdbc.StatementProvider

setTablePrefix

public void setTablePrefix(java.lang.String tablePrefix)
Specified by:
setTablePrefix in interface org.activemq.store.jdbc.StatementProvider

getTablePrefix

public java.lang.String getTablePrefix()
Specified by:
getTablePrefix in interface org.activemq.store.jdbc.StatementProvider
Overview  Package   Class  Use  Deprecated  Index 
Home >> All >> org >> activemq >> store >> jdbc >> [ adapter overview ]  PREV CLASS  NEXT CLASS
SUMMARY: JavaDoc of org.activemq.store.jdbc.adapter.CachingStatementProvider JAVADOC | Sourc code of org.activemq.store.jdbc.adapter.CachingStatementProvider SOURCE | Download org.activemq.store.jdbc.adapter.CachingStatementProvider DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD