Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
org.apache.activemq.broker.ft |
Helper classes for implementing fault tolerance
|
org.apache.activemq.broker.region |
Region abstraction and implementations in the Broker.
|
org.apache.activemq.broker.util |
Some utility Broker Plugins
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.kaha |
fast message persistence implementation
|
org.apache.activemq.state | |
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 | Method and Description |
---|---|
protected void |
ActiveMQSession.sendAck(MessageAck ack) |
protected void |
ActiveMQSession.sendAck(MessageAck ack,
boolean lazy) |
Modifier and Type | Method and Description |
---|---|
void |
BrokerBroadcaster.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
MutableBrokerFilter.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
ErrorBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
TransactionBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
BrokerFilter.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
EmptyBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
Response |
TransportConnection.processMessageAck(MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
void |
MasterBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
protected void |
MasterBroker.sendToSlave(MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
void |
PrefetchSubscription.acknowledge(ConnectionContext context,
MessageAck ack) |
void |
Subscription.acknowledge(ConnectionContext context,
MessageAck ack)
Used when client acknowledge receipt of dispatched message.
|
void |
TopicSubscription.acknowledge(ConnectionContext context,
MessageAck ack) |
protected abstract void |
PrefetchSubscription.acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference node)
Used during acknowledgment to remove the message.
|
protected void |
QueueBrowserSubscription.acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference n)
Since we are a browser we don't really remove the message from the queue.
|
protected void |
DurableTopicSubscription.acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference node) |
protected void |
QueueSubscription.acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference n)
In the queue case, mark the node as dropped and then a gc cycle will
remove it from the queue.
|
void |
Queue.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
Topic.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
DestinationFilter.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
Destination.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
AbstractRegion.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
RegionBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
Region.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
Used to acknowledge the receipt of a message by a client.
|
protected void |
PrefetchSubscription.assertAckMatchesDispatched(MessageAck ack)
Checks an ack versus the contents of the dispatched list.
|
protected void |
Queue.removeMessage(ConnectionContext context,
Subscription sub,
QueueMessageReference reference,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingBrokerPlugin.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
DestinationPathSeparatorBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
UDPTraceBrokerPlugin.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
MessageAck |
JournalQueueAck.getMessageAck() |
Modifier and Type | Method and Description |
---|---|
ArrayList<MessageAck> |
XATransactionId.getPreparedAcks() |
Modifier and Type | Method and Description |
---|---|
void |
MessageAck.copy(MessageAck copy) |
void |
JournalQueueAck.setMessageAck(MessageAck messageAck) |
Modifier and Type | Method and Description |
---|---|
void |
XATransactionId.setPreparedAcks(ArrayList<MessageAck> preparedAcks) |
Modifier and Type | Class and Description |
---|---|
class |
MessageAckWithLocation |
Constructor and Description |
---|
MessageAckWithLocation(MessageAck ack,
Location location) |
Modifier and Type | Method and Description |
---|---|
Response |
CommandVisitor.processMessageAck(MessageAck ack) |
Response |
CommandVisitorAdapter.processMessageAck(MessageAck ack) |
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
|
void |
TransactionRecoveryListener.recover(XATransactionId xid,
Message[] addedMessages,
MessageAck[] aks) |
void |
MessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
ProxyTopicMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
ProxyMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
AbstractMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
MessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
Removes a message from the message store.
|
void |
ProxyTopicMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
void |
ProxyMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
MessageAck[] |
AMQTx.getAcks() |
Modifier and Type | Method and Description |
---|---|
void |
AMQTopicMessageStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck originalAck) |
void |
AMQTx.add(AMQMessageStore store,
MessageAck ack) |
void |
AMQTransactionStore.removeMessage(AMQMessageStore store,
MessageAck ack,
Location location) |
void |
AMQMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
boolean |
AMQMessageStore.replayRemoveMessage(ConnectionContext context,
MessageAck messageAck) |
Modifier and Type | Method and Description |
---|---|
void |
JDBCTopicMessageStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
void |
JDBCMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
MessageAck[] |
JournalTransactionStore.Tx.getAcks() |
Modifier and Type | Method and Description |
---|---|
void |
JournalTopicMessageStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck originalAck) |
void |
JournalTransactionStore.Tx.add(JournalMessageStore store,
MessageAck ack) |
void |
JournalMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
void |
JournalTransactionStore.removeMessage(JournalMessageStore store,
MessageAck ack,
org.apache.activeio.journal.RecordLocation location) |
void |
JournalMessageStore.replayRemoveMessage(ConnectionContext context,
MessageAck messageAck) |
Modifier and Type | Method and Description |
---|---|
void |
KahaTopicMessageStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
void |
KahaTopicReferenceStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
void |
KahaMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
void |
KahaReferenceStore.removeMessage(ConnectionContext context,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
MessageAck[] |
KahaDBTransactionStore.Tx.getAcks() |
Modifier and Type | Method and Description |
---|---|
void |
KahaDBStore.KahaDBMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
TempKahaDBStore.KahaDBMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
void |
KahaDBStore.KahaDBMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
void |
MessageDatabase.forgetRecoveredAcks(ArrayList<MessageAck> acks) |
void |
MessageDatabase.trackRecoveredAcks(ArrayList<MessageAck> acks) |
Modifier and Type | Method and Description |
---|---|
MessageAck[] |
MemoryTransactionStore.Tx.getAcks() |
MessageAck |
MemoryTransactionStore.RemoveMessageCommand.getMessageAck() |
Modifier and Type | Method and Description |
---|---|
void |
MemoryTopicMessageStore.acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
void |
MemoryMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.