|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
ProxyMessageStore.recover(MessageRecoveryListener listener)
|
void |
ProxyTopicMessageStore.recover(MessageRecoveryListener listener)
|
void |
MessageStore.recover(MessageRecoveryListener container)
Recover any messages to be delivered. |
void |
ProxyMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener)
|
void |
ProxyTopicMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener)
|
void |
MessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener)
|
void |
ProxyTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
int maxReturned,
MessageRecoveryListener listener)
|
void |
TopicReferenceStore.recoverNextMessages(java.lang.String clientId,
java.lang.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(java.lang.String clientId,
java.lang.String subscriptionName,
int maxReturned,
MessageRecoveryListener listener)
For an active subscription - retrieve messages from the store for the subscriber after the lastMessageId messageId |
void |
ProxyTopicMessageStore.recoverSubscription(java.lang.String clientId,
java.lang.String subscriptionName,
MessageRecoveryListener listener)
|
void |
TopicReferenceStore.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 |
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. |
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(java.lang.String clientId,
java.lang.String subscriptionName,
int maxReturned,
MessageRecoveryListener listener)
|
void |
AMQTopicMessageStore.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 |
JDBCMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener)
|
void |
JDBCTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
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 |
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(java.lang.String clientId,
java.lang.String subscriptionName,
int maxReturned,
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 |
KahaReferenceStore.recover(MessageRecoveryListener listener)
|
protected boolean |
KahaMessageStore.recoverMessage(MessageRecoveryListener listener,
Message msg)
|
void |
KahaMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener)
|
void |
KahaReferenceStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener)
|
void |
KahaTopicReferenceStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
int maxReturned,
MessageRecoveryListener listener)
|
void |
KahaTopicMessageStore.recoverNextMessages(java.lang.String clientId,
java.lang.String subscriptionName,
int maxReturned,
MessageRecoveryListener listener)
|
protected boolean |
KahaReferenceStore.recoverReference(MessageRecoveryListener listener,
ReferenceRecord record)
|
void |
KahaTopicReferenceStore.recoverSubscription(java.lang.String clientId,
java.lang.String subscriptionName,
MessageRecoveryListener listener)
|
void |
KahaTopicMessageStore.recoverSubscription(java.lang.String clientId,
java.lang.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(java.lang.String clientId,
java.lang.String subscriptionName,
int maxReturned,
MessageRecoveryListener listener)
|
void |
MemoryTopicMessageStore.recoverSubscription(java.lang.String clientId,
java.lang.String subscriptionName,
MessageRecoveryListener listener)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |