|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use RecoveryListener | |
org.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.activemq.store.cache | |
org.activemq.store.jdbc | Message persistence implemented using JDBC |
org.activemq.store.journal | Message persistence using a high performance transaction log via the Journal interface. |
org.activemq.store.vm | VM based implementation of message persistence |
Uses of RecoveryListener in org.activemq.store |
Methods in org.activemq.store with parameters of type RecoveryListener | |
void |
ProxyMessageStore.recover(RecoveryListener listener)
|
void |
MessageStore.recover(RecoveryListener container)
Recover any messages to be delivered. |
void |
TopicMessageStore.recoverSubscription(String subscriptionId,
MessageIdentity lastDispatchedMessage,
RecoveryListener listener)
For the new subcription find the last acknowledged message ID and then find any new messages since then and dispatch them to the subscription. |
void |
ProxyTopicMessageStore.recover(RecoveryListener listener)
|
void |
ProxyTopicMessageStore.recoverSubscription(String subscriptionId,
MessageIdentity lastDispatchedMessage,
RecoveryListener listener)
|
Uses of RecoveryListener in org.activemq.store.cache |
Methods in org.activemq.store.cache with parameters of type RecoveryListener | |
void |
CacheTopicMessageStore.recoverSubscription(String subscriptionId,
MessageIdentity lastDispatchedMessage,
RecoveryListener listener)
|
void |
CacheMessageStore.recover(RecoveryListener 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. |
Uses of RecoveryListener in org.activemq.store.jdbc |
Methods in org.activemq.store.jdbc with parameters of type RecoveryListener | |
void |
JDBCTopicMessageStore.recoverSubscription(String subscriptionId,
MessageIdentity lastDispatchedMessage,
RecoveryListener listener)
|
void |
JDBCMessageStore.recover(RecoveryListener listener)
|
Uses of RecoveryListener in org.activemq.store.journal |
Methods in org.activemq.store.journal with parameters of type RecoveryListener | |
void |
JournalTopicMessageStore.recoverSubscription(String subscriptionId,
MessageIdentity lastDispatchedMessage,
RecoveryListener listener)
|
void |
JournalMessageStore.recover(RecoveryListener 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. |
Uses of RecoveryListener in org.activemq.store.vm |
Methods in org.activemq.store.vm with parameters of type RecoveryListener | |
void |
VMMessageStore.recover(RecoveryListener listener)
|
void |
VMTopicMessageStore.recoverSubscription(String subscriptionId,
MessageIdentity lastDispatchedMessage,
RecoveryListener listener)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |