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.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.state | |
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
|
org.apache.activemq.transport.mqtt |
A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/
|
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 |
EmptyBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
MutableBrokerFilter.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
TransactionBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
BrokerBroadcaster.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
ErrorBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
BrokerFilter.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
Response |
TransportConnection.processMessageAck(MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
protected MessageAck |
BaseDestination.convertToNonRangedAck(MessageAck ack,
MessageReference node) |
Modifier and Type | Method and Description |
---|---|
void |
Subscription.acknowledge(ConnectionContext context,
MessageAck ack)
Used when client acknowledge receipt of dispatched message.
|
void |
TopicSubscription.acknowledge(ConnectionContext context,
MessageAck ack) |
void |
PrefetchSubscription.acknowledge(ConnectionContext context,
MessageAck ack) |
void |
AbstractSubscription.acknowledge(ConnectionContext context,
MessageAck ack) |
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 abstract void |
PrefetchSubscription.acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference node)
Used during acknowledgment to remove the message.
|
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 |
Topic.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
Queue.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
Destination.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
DestinationFilter.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
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.
|
void |
AbstractRegion.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
protected void |
PrefetchSubscription.assertAckMatchesDispatched(MessageAck ack)
Checks an ack versus the contents of the dispatched list.
|
protected MessageAck |
BaseDestination.convertToNonRangedAck(MessageAck ack,
MessageReference node) |
protected void |
Queue.removeMessage(ConnectionContext context,
Subscription sub,
QueueMessageReference reference,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
void |
UDPTraceBrokerPlugin.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
DestinationPathSeparatorBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack) |
void |
LoggingBrokerPlugin.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 | 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 |
AbstractMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
ProxyTopicMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
ProxyMessageStore.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[] |
KahaDBTransactionStore.Tx.getAcks() |
Modifier and Type | Method and Description |
---|---|
void |
KahaDBStore.KahaDBMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
KahaDBStore.KahaDBMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
void |
TempKahaDBStore.KahaDBMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
void |
MessageDatabase.forgetRecoveredAcks(ArrayList<MessageAck> acks,
boolean rollback) |
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 |
MemoryTransactionStore.acknowledge(TopicMessageStore destination,
String clientId,
String subscriptionName,
MessageId messageId,
MessageAck ack) |
void |
MemoryMessageStore.removeMessage(ConnectionContext context,
MessageAck ack) |
Modifier and Type | Method and Description |
---|---|
MessageAck |
MQTTSubscription.createMessageAck(MessageDispatch md)
Create a
MessageAck that will acknowledge the given MessageDispatch . |
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.