|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MessageAck | |
---|---|
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 |
org.apache.activemq.transport.stomp | An implementation of the Stomp protocol which is a simple wire protocol for writing clients for ActiveMQ in different languages like Ruby, Python, PHP, C etc. |
Uses of MessageAck in org.apache.activemq |
---|
Methods in org.apache.activemq with parameters of type MessageAck | |
---|---|
protected void |
ActiveMQSession.sendAck(MessageAck ack)
|
protected void |
ActiveMQSession.sendAck(MessageAck ack,
boolean lazy)
|
Uses of MessageAck in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker with parameters of type MessageAck | |
---|---|
void |
BrokerBroadcaster.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
void |
TransactionBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
void |
BrokerFilter.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
void |
MutableBrokerFilter.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
void |
ErrorBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
void |
EmptyBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
Response |
TransportConnection.processMessageAck(MessageAck ack)
|
Uses of MessageAck in org.apache.activemq.broker.ft |
---|
Methods in org.apache.activemq.broker.ft with parameters of type MessageAck | |
---|---|
void |
MasterBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
protected void |
MasterBroker.sendToSlave(MessageAck ack)
|
Uses of MessageAck in org.apache.activemq.broker.region |
---|
Methods in org.apache.activemq.broker.region with parameters of type MessageAck | |
---|---|
void |
TopicSubscription.acknowledge(ConnectionContext context,
MessageAck ack)
|
void |
PrefetchSubscription.acknowledge(ConnectionContext context,
MessageAck ack)
|
void |
Subscription.acknowledge(ConnectionContext context,
MessageAck ack)
Used when client acknowledge receipt of dispatched 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. |
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. |
void |
Queue.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node)
|
void |
Topic.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 |
AbstractRegion.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)
|
Uses of MessageAck in org.apache.activemq.broker.util |
---|
Methods in org.apache.activemq.broker.util with parameters of type MessageAck | |
---|---|
void |
LoggingBrokerPlugin.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
void |
UDPTraceBrokerPlugin.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
void |
DestinationPathSeparatorBroker.acknowledge(ConsumerBrokerExchange consumerExchange,
MessageAck ack)
|
Uses of MessageAck in org.apache.activemq.command |
---|
Methods in org.apache.activemq.command that return MessageAck | |
---|---|
MessageAck |
JournalQueueAck.getMessageAck()
|
Methods in org.apache.activemq.command that return types with arguments of type MessageAck | |
---|---|
java.util.ArrayList<MessageAck> |
XATransactionId.getPreparedAcks()
|
Methods in org.apache.activemq.command with parameters of type MessageAck | |
---|---|
void |
MessageAck.copy(MessageAck copy)
|
void |
JournalQueueAck.setMessageAck(MessageAck messageAck)
|
Method parameters in org.apache.activemq.command with type arguments of type MessageAck | |
---|---|
void |
XATransactionId.setPreparedAcks(java.util.ArrayList<MessageAck> preparedAcks)
|
Uses of MessageAck in org.apache.activemq.kaha |
---|
Subclasses of MessageAck in org.apache.activemq.kaha | |
---|---|
class |
MessageAckWithLocation
|
Constructors in org.apache.activemq.kaha with parameters of type MessageAck | |
---|---|
MessageAckWithLocation(MessageAck ack,
Location location)
|
Uses of MessageAck in org.apache.activemq.state |
---|
Methods in org.apache.activemq.state with parameters of type MessageAck | |
---|---|
Response |
CommandVisitor.processMessageAck(MessageAck ack)
|
Response |
CommandVisitorAdapter.processMessageAck(MessageAck ack)
|
Uses of MessageAck in org.apache.activemq.store |
---|
Methods in org.apache.activemq.store with parameters of type MessageAck | |
---|---|
void |
TopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.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 |
ProxyTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck ack)
|
void |
TransactionRecoveryListener.recover(XATransactionId xid,
Message[] addedMessages,
MessageAck[] aks)
|
void |
MessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack)
|
void |
ProxyMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack)
|
void |
AbstractMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack)
|
void |
ProxyTopicMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack)
|
void |
MessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
Removes a message from the message store. |
void |
ProxyMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
void |
ProxyTopicMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
Uses of MessageAck in org.apache.activemq.store.amq |
---|
Methods in org.apache.activemq.store.amq that return MessageAck | |
---|---|
MessageAck[] |
AMQTx.getAcks()
|
Methods in org.apache.activemq.store.amq with parameters of type MessageAck | |
---|---|
void |
AMQTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.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)
|
Uses of MessageAck in org.apache.activemq.store.jdbc |
---|
Methods in org.apache.activemq.store.jdbc with parameters of type MessageAck | |
---|---|
void |
JDBCTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck ack)
|
void |
JDBCMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
Uses of MessageAck in org.apache.activemq.store.journal |
---|
Methods in org.apache.activemq.store.journal that return MessageAck | |
---|---|
MessageAck[] |
JournalTransactionStore.Tx.getAcks()
|
Methods in org.apache.activemq.store.journal with parameters of type MessageAck | |
---|---|
void |
JournalTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.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)
|
Uses of MessageAck in org.apache.activemq.store.kahadaptor |
---|
Methods in org.apache.activemq.store.kahadaptor with parameters of type MessageAck | |
---|---|
void |
KahaTopicReferenceStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck ack)
|
void |
KahaTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck ack)
|
void |
KahaMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
void |
KahaReferenceStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
Uses of MessageAck in org.apache.activemq.store.kahadb |
---|
Methods in org.apache.activemq.store.kahadb that return MessageAck | |
---|---|
MessageAck[] |
KahaDBTransactionStore.Tx.getAcks()
|
Methods in org.apache.activemq.store.kahadb with parameters of type MessageAck | |
---|---|
void |
KahaDBStore.KahaDBMessageStore.removeAsyncMessage(ConnectionContext context,
MessageAck ack)
|
void |
TempKahaDBStore.KahaDBMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
void |
KahaDBStore.KahaDBMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
Method parameters in org.apache.activemq.store.kahadb with type arguments of type MessageAck | |
---|---|
void |
MessageDatabase.forgetRecoveredAcks(java.util.ArrayList<MessageAck> acks)
|
void |
MessageDatabase.trackRecoveredAcks(java.util.ArrayList<MessageAck> acks)
|
Uses of MessageAck in org.apache.activemq.store.memory |
---|
Methods in org.apache.activemq.store.memory that return MessageAck | |
---|---|
MessageAck[] |
MemoryTransactionStore.Tx.getAcks()
|
MessageAck |
MemoryTransactionStore.RemoveMessageCommand.getMessageAck()
|
Methods in org.apache.activemq.store.memory with parameters of type MessageAck | |
---|---|
void |
MemoryTopicMessageStore.acknowledge(ConnectionContext context,
java.lang.String clientId,
java.lang.String subscriptionName,
MessageId messageId,
MessageAck ack)
|
void |
MemoryMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
Uses of MessageAck in org.apache.activemq.transport.stomp |
---|
Methods in org.apache.activemq.transport.stomp that return MessageAck | |
---|---|
MessageAck |
StompQueueBrowserSubscription.onStompMessageNack(java.lang.String messageId,
TransactionId transactionId)
|
MessageAck |
StompSubscription.onStompMessageNack(java.lang.String messageId,
TransactionId transactionId)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |