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

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.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 TransactionBroker.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)
           
 void BrokerFilter.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
           
 void BrokerBroadcaster.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
           
 Response TransportConnection.processMessageAck(MessageAck ack)
           
 

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

Methods in org.apache.activemq.broker.region that return MessageAck
protected  MessageAck BaseDestination.convertToNonRangedAck(MessageAck ack, MessageReference node)
           
 

Methods in org.apache.activemq.broker.region with parameters of type MessageAck
 void TopicSubscription.acknowledge(ConnectionContext context, MessageAck ack)
           
 void Subscription.acknowledge(ConnectionContext context, MessageAck ack)
          Used when client acknowledge receipt of dispatched message.
 void PrefetchSubscription.acknowledge(ConnectionContext context, MessageAck ack)
           
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 abstract  void PrefetchSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference node)
          Used during acknowledgment to remove the message.
protected  void DurableTopicSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference node)
           
 void Topic.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 Destination.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)
           
 

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

Methods in org.apache.activemq.broker.util with parameters of type MessageAck
 void UDPTraceBrokerPlugin.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
           
 void LoggingBrokerPlugin.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
 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(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 CommandVisitorAdapter.processMessageAck(MessageAck ack)
           
 Response CommandVisitor.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, 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 ProxyTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void TransactionRecoveryListener.recover(XATransactionId xid, Message[] addedMessages, MessageAck[] aks)
           
 void ProxyTopicMessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void ProxyMessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void MessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void AbstractMessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
           
 void ProxyTopicMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void ProxyMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void MessageStore.removeMessage(ConnectionContext context, MessageAck ack)
          Removes a message from the message store.
 

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, 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)
           
 

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, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void JdbcMemoryTransactionStore.acknowledge(TopicMessageStore topicMessageStore, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void JDBCPersistenceAdapter.commitRemove(ConnectionContext context, MessageAck ack)
           
 void JDBCMessageStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void JDBCPersistenceAdapter.rollbackLastAck(ConnectionContext context, JDBCTopicMessageStore store, MessageAck ack, String subName, String clientId)
           
 

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, 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)
           
 

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, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void KahaTopicMessageStore.acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
           
 void KahaReferenceStore.removeMessage(ConnectionContext context, MessageAck ack)
           
 void KahaMessageStore.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(ArrayList<MessageAck> acks)
           
 void MessageDatabase.trackRecoveredAcks(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, 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)
           
 

Uses of MessageAck in org.apache.activemq.transport.stomp
 

Methods in org.apache.activemq.transport.stomp that return MessageAck
 MessageAck StompSubscription.onStompMessageNack(String messageId, TransactionId transactionId)
           
 MessageAck StompQueueBrowserSubscription.onStompMessageNack(String messageId, TransactionId transactionId)
           
 



Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.