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

Packages that use MessageRecoveryListener
org.apache.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging 
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.memory VM based implementation of message persistence 
org.apache.activemq.store.rapid   
 

Uses of MessageRecoveryListener in org.apache.activemq.store
 

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

 void ProxyTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void TopicMessageStore.recoverSubscription(java.lang.String clientId, java.lang.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(java.lang.String clientId, java.lang.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 JDBCTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void JDBCTopicMessageStore.recoverSubscription(java.lang.String clientId, java.lang.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 QuickJournalMessageStore.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.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 QuickJournalTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void JournalTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void QuickJournalTopicMessageStore.recoverSubscription(java.lang.String clientId, java.lang.String subscriptionName, MessageRecoveryListener listener)
           
 void JournalTopicMessageStore.recoverSubscription(java.lang.String clientId, java.lang.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 KahaMessageStore.recover(MessageRecoveryListener listener)
           
 void KahaTopicMessageStore.recover(MessageRecoveryListener listener)
           
 void KahaTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void KahaTopicMessageStore.recoverSubscription(java.lang.String clientId, java.lang.String subscriptionName, 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 MemoryTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void MemoryTopicMessageStore.recoverSubscription(java.lang.String clientId, java.lang.String subscriptionName, MessageRecoveryListener listener)
           
 

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

Methods in org.apache.activemq.store.rapid with parameters of type MessageRecoveryListener
 void RapidMessageStore.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 RapidTopicMessageStore.recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener)
           
 void RapidTopicMessageStore.recoverSubscription(java.lang.String clientId, java.lang.String subscriptionName, MessageRecoveryListener listener)
           
 



Copyright © 2010 Apache Software Foundation. All Rights Reserved.