Uses of Class
org.apache.activemq.command.MessageAck

Packages that use MessageAck
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.state   
org.apache.activemq.store The APIs which need to be implemented for persistent message stores for durable messaging 
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.memory VM based implementation of message persistence 
org.apache.activemq.store.rapid   
 

Uses of MessageAck in org.apache.activemq.broker
 

Methods in org.apache.activemq.broker with parameters of type MessageAck
 void MutableBrokerFilter.acknowledge(ConnectionContext context, MessageAck ack)
           
 void BrokerFilter.acknowledge(ConnectionContext context, MessageAck ack)
           
 void TransactionBroker.acknowledge(ConnectionContext context, MessageAck ack)
           
 void ErrorBroker.acknowledge(ConnectionContext context, MessageAck ack)
           
 void EmptyBroker.acknowledge(ConnectionContext context, MessageAck ack)
           
 void BrokerBroadcaster.acknowledge(ConnectionContext context, 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(ConnectionContext context, 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 Subscription.acknowledge(ConnectionContext context, MessageAck ack)
          Used when client acknowledge receipt of dispatched message.
 void Region.acknowledge(ConnectionContext context, MessageAck ack)
          Used to acknowledge the receipt of a message by a client.
 void TopicSubscription.acknowledge(ConnectionContext context, MessageAck ack)
           
 void RegionBroker.acknowledge(ConnectionContext context, MessageAck ack)
           
 void AbstractRegion.acknowledge(ConnectionContext context, MessageAck ack)
           
 void PrefetchSubscription.acknowledge(ConnectionContext context, MessageAck ack)
           
protected  void DurableTopicSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference node)
           
protected  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.
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.
 void Destination.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Queue.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void DestinationFilter.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 void Topic.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
           
 

Uses of MessageAck in org.apache.activemq.broker.util
 

Methods in org.apache.activemq.broker.util with parameters of type MessageAck
 void LoggingBrokerPlugin.acknowledge(ConnectionContext context, MessageAck ack)
           
 void UDPTraceBrokerPlugin.acknowledge(ConnectionContext context, 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 with parameters of type MessageAck
 void MessageAck.copy(MessageAck copy)
           
 void JournalQueueAck.setMessageAck(MessageAck messageAck)
           
 

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 ConnectionStateTracker.processMessageAck(MessageAck ack)
           
 

Uses of MessageAck in org.apache.activemq.store
 

Methods in org.apache.activemq.store with parameters of type MessageAck
 void TransactionRecoveryListener.recover(XATransactionId xid, Message[] addedMessages, MessageAck[] aks)
           
 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)
           
 

Uses of MessageAck in org.apache.activemq.store.jdbc
 

Methods in org.apache.activemq.store.jdbc with parameters of type MessageAck
 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[] QuickJournalTransactionStore.Tx.getAcks()
           
 MessageAck[] JournalTransactionStore.Tx.getAcks()
           
 

Methods in org.apache.activemq.store.journal with parameters of type MessageAck
 void JournalTransactionStore.Tx.add(JournalMessageStore store, MessageAck ack)
           
 void QuickJournalTransactionStore.Tx.add(QuickJournalMessageStore store, MessageAck ack, org.apache.activeio.journal.RecordLocation loc)
           
 void QuickJournalMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void JournalMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void JournalTransactionStore.removeMessage(JournalMessageStore store, MessageAck ack, org.apache.activeio.journal.RecordLocation location)
           
 void QuickJournalTransactionStore.removeMessage(QuickJournalMessageStore store, MessageAck ack, org.apache.activeio.journal.RecordLocation location)
           
 void QuickJournalMessageStore.replayRemoveMessage(ConnectionContext context, MessageAck messageAck)
           
 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 KahaTopicMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void KahaMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 

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 MemoryMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 

Uses of MessageAck in org.apache.activemq.store.rapid
 

Methods in org.apache.activemq.store.rapid that return MessageAck
 MessageAck[] RapidTransactionStore.Tx.getAcks()
           
 

Methods in org.apache.activemq.store.rapid with parameters of type MessageAck
 void RapidTransactionStore.Tx.add(RapidMessageStore store, MessageAck ack, org.apache.activeio.journal.RecordLocation loc)
           
 void RapidMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void RapidTransactionStore.removeMessage(RapidMessageStore store, MessageAck ack, org.apache.activeio.journal.RecordLocation location)
           
 void RapidMessageStore.replayRemoveMessage(ConnectionContext context, MessageAck ack)
           
 



Copyright © 2011 Apache Software Foundation. All Rights Reserved.