|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |