Package | Description |
---|---|
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.kahadb | |
org.apache.activemq.store.memory |
VM based implementation of message persistence
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractStoreCursor
Store based cursor
|
Modifier and Type | Method and Description |
---|---|
void |
MessageStore.recover(MessageRecoveryListener container)
Recover any messages to be delivered.
|
void |
ProxyMessageStore.recover(MessageRecoveryListener listener) |
void |
ProxyTopicMessageStore.recover(MessageRecoveryListener listener) |
void |
MessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
void |
ProxyMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
void |
ProxyTopicMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
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.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.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) |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
KahaDBStore.KahaDBMessageStore.recover(MessageRecoveryListener listener) |
void |
TempKahaDBStore.KahaDBMessageStore.recover(MessageRecoveryListener listener) |
void |
KahaDBStore.KahaDBMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
void |
TempKahaDBStore.KahaDBMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
protected int |
KahaDBStore.KahaDBMessageStore.recoverRolledBackAcks(org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd,
Transaction tx,
int maxReturned,
MessageRecoveryListener listener) |
Modifier and Type | Method and Description |
---|---|
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–2016 The Apache Software Foundation. All rights reserved.