Uses of Interface
org.apache.activemq.store.MessageRecoveryListener

Packages that use MessageRecoveryListener
org.apache.activemq.broker.region.cursors Cursors used to page persistent messages into the broker from the store 
org.apache.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging 
org.apache.activemq.store.amq The default Store implementation for ActiveMQ 
org.apache.activemq.store.jdbc Message persistence implemented using JDBC 
org.apache.activemq.store.journal Message persistence using a high performance transaction log via the Journal interface. 
org.apache.activemq.store.kahadaptor kaha implementation of message persistence for the broker 
org.apache.activemq.store.kahadb   
org.apache.activemq.store.memory VM based implementation of message persistence 
 

Uses of MessageRecoveryListener in org.apache.activemq.broker.region.cursors
 

Classes in org.apache.activemq.broker.region.cursors that implement MessageRecoveryListener
 class AbstractStoreCursor
          Store based cursor
 

Uses of MessageRecoveryListener in org.apache.activemq.store
 

Methods in org.apache.activemq.store with parameters of type MessageRecoveryListener
 void ProxyTopicMessageStore.recover(MessageRecoveryListener listener)
           
 void ProxyMessageStore.recover(MessageRecoveryListener listener)
           
 void MessageStore.recover(MessageRecoveryListener container)
          Recover any messages to be delivered.
 void ProxyTopicMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void ProxyMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void MessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void TopicReferenceStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
          For an active subscription - retrieve messages from the store for the subscriber after the lastMessageId messageId

 void TopicMessageStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
          For an active subscription - retrieve messages from the store for the subscriber after the lastMessageId messageId

 void ProxyTopicMessageStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
           
 void TopicReferenceStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
          For the new subscription find the last acknowledged message ID and then find any new messages since then and dispatch them to the subscription.
 void TopicMessageStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
          For the new subscription find the last acknowledged message ID and then find any new messages since then and dispatch them to the subscription.
 void ProxyTopicMessageStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
           
 

Uses of MessageRecoveryListener in org.apache.activemq.store.amq
 

Methods in org.apache.activemq.store.amq with parameters of type MessageRecoveryListener
 void AMQMessageStore.recover(MessageRecoveryListener listener)
          Replays the referenceStore first as those messages are the oldest ones, then messages are replayed from the transaction log and then the cache is updated.
 void AMQMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void AMQTopicMessageStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
           
 void AMQTopicMessageStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
           
 

Uses of MessageRecoveryListener in org.apache.activemq.store.jdbc
 

Methods in org.apache.activemq.store.jdbc with parameters of type MessageRecoveryListener
 void JDBCMessageStore.recover(MessageRecoveryListener listener)
           
 void JDBCMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void JDBCTopicMessageStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
           
 void JDBCTopicMessageStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
           
 

Uses of MessageRecoveryListener in org.apache.activemq.store.journal
 

Methods in org.apache.activemq.store.journal with parameters of type MessageRecoveryListener
 void JournalMessageStore.recover(MessageRecoveryListener listener)
          Replays the checkpointStore first as those messages are the oldest ones, then messages are replayed from the transaction log and then the cache is updated.
 void JournalMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void JournalTopicMessageStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
           
 void JournalTopicMessageStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
           
 

Uses of MessageRecoveryListener in org.apache.activemq.store.kahadaptor
 

Methods in org.apache.activemq.store.kahadaptor with parameters of type MessageRecoveryListener
 void KahaReferenceStore.recover(MessageRecoveryListener listener)
           
 void KahaMessageStore.recover(MessageRecoveryListener listener)
           
protected  boolean KahaMessageStore.recoverMessage(MessageRecoveryListener listener, Message msg)
           
 void KahaReferenceStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void KahaMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void KahaTopicReferenceStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
           
 void KahaTopicMessageStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
           
protected  boolean KahaReferenceStore.recoverReference(MessageRecoveryListener listener, ReferenceRecord record)
           
 void KahaTopicReferenceStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
           
 void KahaTopicMessageStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
           
 

Uses of MessageRecoveryListener in org.apache.activemq.store.kahadb
 

Methods in org.apache.activemq.store.kahadb with parameters of type MessageRecoveryListener
 void TempKahaDBStore.KahaDBMessageStore.recover(MessageRecoveryListener listener)
           
 void KahaDBStore.KahaDBMessageStore.recover(MessageRecoveryListener listener)
           
 void TempKahaDBStore.KahaDBMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void KahaDBStore.KahaDBMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 

Uses of MessageRecoveryListener in org.apache.activemq.store.memory
 

Methods in org.apache.activemq.store.memory with parameters of type MessageRecoveryListener
 void MemoryMessageStore.recover(MessageRecoveryListener listener)
           
 void MemoryMessageStore.recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
           
 void MemoryTopicMessageStore.recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener)
           
 void MemoryTopicMessageStore.recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener)
           
 



Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.