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

Packages that use MessageAck

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.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.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/
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

Modifier and Type	Method	Description
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

Modifier and Type	Method	Description
void	BrokerBroadcaster.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
void	BrokerFilter.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
void	EmptyBroker.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
void	ErrorBroker.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
void	TransactionBroker.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

Modifier and Type	Method	Description
protected MessageAck	BaseDestination.convertToNonRangedAck(MessageAck ack, MessageReference node)

Methods in org.apache.activemq.broker.region with parameters of type MessageAck

Modifier and Type	Method	Description
void	AbstractRegion.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
void	AbstractSubscription.acknowledge(ConnectionContext context, MessageAck ack)
void	Destination.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
void	DestinationFilter.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
protected void	DurableTopicSubscription.acknowledge(ConnectionContext context, MessageAck ack, MessageReference node)
void	PrefetchSubscription.acknowledge(ConnectionContext context, MessageAck ack)
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)
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	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	Region.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)	Used to acknowledge the receipt of a message by a client.
void	RegionBroker.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
void	Subscription.acknowledge(ConnectionContext context, MessageAck ack)	Used when client acknowledge receipt of dispatched message.
void	Topic.acknowledge(ConnectionContext context, Subscription sub, MessageAck ack, MessageReference node)
void	TopicSubscription.acknowledge(ConnectionContext context, 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

Modifier and Type	Method	Description
void	DestinationPathSeparatorBroker.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
void	LoggingBrokerPlugin.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)
void	UDPTraceBrokerPlugin.acknowledge(ConsumerBrokerExchange consumerExchange, MessageAck ack)

Uses of MessageAck in org.apache.activemq.command

Methods in org.apache.activemq.command that return MessageAck

Modifier and Type	Method	Description
MessageAck	JournalQueueAck.getMessageAck()

Methods in org.apache.activemq.command that return types with arguments of type MessageAck

Modifier and Type	Method	Description
ArrayList<MessageAck>	XATransactionId.getPreparedAcks()

Methods in org.apache.activemq.command with parameters of type MessageAck

Modifier and Type	Method	Description
void	MessageAck.copy(MessageAck copy)
void	JournalQueueAck.setMessageAck(MessageAck messageAck)

Method parameters in org.apache.activemq.command with type arguments of type MessageAck

Modifier and Type	Method	Description
void	XATransactionId.setPreparedAcks(ArrayList<MessageAck> preparedAcks)

Uses of MessageAck in org.apache.activemq.state

Methods in org.apache.activemq.state with parameters of type MessageAck

Modifier and Type	Method	Description
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

Modifier and Type	Method	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	AbstractMessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
void	MessageStore.removeAsyncMessage(ConnectionContext context, MessageAck ack)
void	ProxyMessageStore.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.jdbc

Methods in org.apache.activemq.store.jdbc with parameters of type MessageAck

Modifier and Type	Method	Description
void	JdbcMemoryTransactionStore.acknowledge(TopicMessageStore topicMessageStore, String clientId, String subscriptionName, MessageId messageId, MessageAck ack)
void	JDBCTopicMessageStore.acknowledge(ConnectionContext context, 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

Modifier and Type	Method	Description
MessageAck[]	JournalTransactionStore.Tx.getAcks()

Methods in org.apache.activemq.store.journal with parameters of type MessageAck

Modifier and Type	Method	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)

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

Methods in org.apache.activemq.store.kahadb that return MessageAck

Modifier and Type	Method	Description
MessageAck[]	KahaDBTransactionStore.Tx.getAcks()

Methods in org.apache.activemq.store.kahadb with parameters of type MessageAck

Modifier and Type	Method	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)

Method parameters in org.apache.activemq.store.kahadb with type arguments of type MessageAck

Modifier and Type	Method	Description
void	KahaDBStore.forgetRecoveredAcks(ArrayList<MessageAck> preparedAcks, boolean isRollback)
void	KahaDBStore.KahaDBMessageStore.forgetRecoveredAcks(ArrayList<MessageAck> acks, boolean rollback)
void	KahaDBStore.KahaDBMessageStore.trackRecoveredAcks(ArrayList<MessageAck> acks)
void	KahaDBStore.trackRecoveredAcks(ArrayList<MessageAck> preparedAcks)

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

Methods in org.apache.activemq.store.memory that return MessageAck

Modifier and Type	Method	Description
MessageAck[]	MemoryTransactionStore.Tx.getAcks()
MessageAck	MemoryTransactionStore.RemoveMessageCommand.getMessageAck()

Methods in org.apache.activemq.store.memory with parameters of type MessageAck

Modifier and Type	Method	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)

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

Methods in org.apache.activemq.transport.mqtt that return MessageAck

Modifier and Type	Method	Description
MessageAck	MQTTSubscription.createMessageAck(MessageDispatch md)	Create a MessageAck that will acknowledge the given MessageDispatch.

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

Methods in org.apache.activemq.transport.stomp that return MessageAck

Modifier and Type	Method	Description
MessageAck	StompAckEntry.onMessageAck(TransactionId transactionId)
MessageAck	StompAckEntry.onMessageNack(TransactionId transactionId)
MessageAck	StompQueueBrowserSubscription.onStompMessageNack(String messageId, TransactionId transactionId)
MessageAck	StompSubscription.onStompMessageNack(String messageId, TransactionId transactionId)