Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
org.apache.activemq.broker.region |
Region abstraction and implementations in the Broker.
|
org.apache.activemq.broker.region.cursors |
Cursors used to page persistent messages into the broker from the store
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.network |
Support for federated networks of brokers.
|
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 | Method and Description |
---|---|
boolean |
ActiveMQMessageAuditNoSync.isDuplicate(MessageId id)
Checks if this messageId has been seen before
|
boolean |
ActiveMQMessageAudit.isDuplicate(MessageId id) |
boolean |
ActiveMQMessageAuditNoSync.isInOrder(MessageId id)
Check the MessageId is in order
|
boolean |
ActiveMQMessageAudit.isInOrder(MessageId id) |
void |
ActiveMQMessageAuditNoSync.rollback(MessageId id)
mark this message as being received
|
void |
ActiveMQMessageAudit.rollback(MessageId id) |
Modifier and Type | Method and Description |
---|---|
MessageId |
NullMessageReference.getMessageId() |
MessageId |
IndirectMessageReference.getMessageId() |
MessageId |
MessageReference.getMessageId() |
Modifier and Type | Method and Description |
---|---|
boolean |
QueueBrowserSubscription.isDuplicate(MessageId messageId) |
Message |
Topic.loadMessage(MessageId messageId) |
Modifier and Type | Method and Description |
---|---|
MessageReference |
OrderedPendingList.get(MessageId messageId) |
MessageReference |
QueueDispatchPendingList.get(MessageId messageId) |
MessageReference |
PrioritizedPendingList.get(MessageId messageId) |
MessageReference |
PendingList.get(MessageId messageId) |
boolean |
AbstractPendingMessageCursor.isDuplicate(MessageId messageId) |
boolean |
AbstractPendingMessageCursor.recordUniqueId(MessageId messageId)
records a message id and checks if it is a duplicate
|
void |
PendingMessageCursor.rollback(MessageId id)
remove from auditing the message id
|
void |
AbstractPendingMessageCursor.rollback(MessageId id) |
protected void |
AbstractStoreCursor.setBatch(MessageId messageId) |
Constructor and Description |
---|
PendingMessageHelper(Map<MessageId,PendingNode> map,
SizeStatisticImpl messageSize) |
Modifier and Type | Field and Description |
---|---|
protected MessageId |
MessageAck.firstMessageId |
protected MessageId |
MessageAck.lastMessageId |
protected MessageId |
MessageDispatchNotification.messageId |
protected MessageId |
Message.messageId |
Modifier and Type | Method and Description |
---|---|
MessageId |
MessageId.copy() |
MessageId |
MessageAck.getFirstMessageId() |
MessageId |
MessageAck.getLastMessageId() |
MessageId |
MessageDispatchNotification.getMessageId() |
MessageId |
MessagePull.getMessageId()
An optional message ID which could be used by a broker to decide which messages are pulled
on demand from a queue for a consumer
|
MessageId |
JournalTopicAck.getMessageId() |
MessageId |
Message.getMessageId() |
Modifier and Type | Method and Description |
---|---|
int |
MessageId.compareTo(MessageId other) |
void |
MessageAck.setFirstMessageId(MessageId firstMessageId) |
void |
MessageAck.setLastMessageId(MessageId lastMessageId) |
void |
MessageDispatchNotification.setMessageId(MessageId messageId) |
void |
MessagePull.setMessageId(MessageId messageId) |
void |
JournalTopicAck.setMessageId(MessageId messageId) |
void |
Message.setMessageId(MessageId messageId) |
void |
MessageAck.setMessageID(MessageId messageID)
A helper method to allow a single message ID to be acknowledged
|
Modifier and Type | Method and Description |
---|---|
protected long |
DemandForwardingBridgeSupport.getStoredSequenceIdForMessage(MessageId messageId) |
Modifier and Type | Method and Description |
---|---|
void |
ProxyTopicMessageStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
void |
TopicMessageStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack)
Stores the last acknowledged messgeID for the given subscription so that
we can recover and commence dispatching messages from the last checkpoint
|
boolean |
TopicReferenceStore.acknowledgeReference(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId)
Removes the last acknowledged messgeID for the given subscription so that
we can recover and commence dispatching messages from the last checkpoint
N.B.
|
boolean |
ReferenceStore.addMessageReference(ConnectionContext context,
MessageId messageId,
ReferenceStore.ReferenceData data)
Adds a message reference to the message store
|
Message |
ProxyTopicMessageStore.getMessage(MessageId identity) |
Message |
MessageStore.getMessage(MessageId identity)
Looks up a message using either the String messageID or the
messageNumber.
|
Message |
ProxyMessageStore.getMessage(MessageId identity) |
ReferenceStore.ReferenceData |
ReferenceStore.getMessageReference(MessageId identity)
Looks up a message using either the String messageID or the
messageNumber.
|
boolean |
MessageRecoveryListener.isDuplicate(MessageId ref)
check if ref is a duplicate but do not record the reference
|
boolean |
MessageRecoveryListener.recoverMessageReference(MessageId ref) |
void |
ProxyTopicMessageStore.setBatch(MessageId messageId) |
void |
MessageStore.setBatch(MessageId messageId)
allow caching cursors to set the current batch offset when cache is exhausted
|
void |
AbstractMessageStore.setBatch(MessageId messageId) |
void |
ReferenceStore.setBatch(MessageId startAfter) |
void |
ProxyMessageStore.setBatch(MessageId messageId) |
Modifier and Type | Method and Description |
---|---|
Message |
TempKahaDBStore.KahaDBMessageStore.getMessage(MessageId identity) |
Message |
KahaDBStore.KahaDBMessageStore.getMessage(MessageId identity) |
protected org.apache.activemq.store.kahadb.KahaDBStore.StoreQueueTask |
KahaDBStore.removeQueueTask(KahaDBStore.KahaDBMessageStore store,
MessageId id) |
protected org.apache.activemq.store.kahadb.KahaDBStore.StoreTopicTask |
KahaDBStore.removeTopicTask(org.apache.activemq.store.kahadb.KahaDBStore.KahaDBTopicMessageStore store,
MessageId id) |
void |
TempKahaDBStore.KahaDBMessageStore.setBatch(MessageId identity) |
void |
KahaDBStore.KahaDBMessageStore.setBatch(MessageId identity) |
Modifier and Type | Field and Description |
---|---|
protected MessageId |
MemoryMessageStore.lastBatchId |
Modifier and Type | Field and Description |
---|---|
protected Map<MessageId,Message> |
MemoryMessageStore.messageTable |
Modifier and Type | Method and Description |
---|---|
void |
MemoryTopicMessageStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
void |
MemoryTransactionStore.acknowledge(TopicMessageStore destination,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
Message |
MemoryMessageStore.getMessage(MessageId identity) |
void |
MemoryMessageStore.removeMessage(MessageId msgId) |
void |
MemoryMessageStore.setBatch(MessageId messageId) |
Constructor and Description |
---|
MemoryMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable) |
MemoryTopicMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable,
Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase) |
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.