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.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
|
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 |
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(String clientId,
String subscriptionName,
int maxReturned,
MessageRecoveryListener listener) |
void |
AMQTopicMessageStore.recoverSubscription(String clientId,
String subscriptionName,
MessageRecoveryListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
JDBCMessageStore.recover(MessageRecoveryListener listener) |
void |
JDBCMessageStore.recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
void |
JDBCTopicMessageStore.recoverNextMessages(String clientId,
String subscriptionName,
int maxReturned,
MessageRecoveryListener listener) |
void |
JDBCTopicMessageStore.recoverSubscription(String clientId,
String subscriptionName,
MessageRecoveryListener listener) |
Modifier and Type | Method and Description |
---|---|
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(String clientId,
String subscriptionName,
int maxReturned,
MessageRecoveryListener listener) |
void |
JournalTopicMessageStore.recoverSubscription(String clientId,
String subscriptionName,
MessageRecoveryListener listener) |
Modifier and Type | Method and Description |
---|---|
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(String clientId,
String subscriptionName,
int maxReturned,
MessageRecoveryListener listener) |
void |
KahaTopicMessageStore.recoverNextMessages(String clientId,
String subscriptionName,
int maxReturned,
MessageRecoveryListener listener) |
protected boolean |
KahaReferenceStore.recoverReference(MessageRecoveryListener listener,
ReferenceRecord record) |
void |
KahaTopicReferenceStore.recoverSubscription(String clientId,
String subscriptionName,
MessageRecoveryListener listener) |
void |
KahaTopicMessageStore.recoverSubscription(String clientId,
String subscriptionName,
MessageRecoveryListener listener) |
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) |
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.