|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 |
EmptyBroker.acknowledge(ConnectionContext context,
MessageAck ack)
|
void |
ErrorBroker.acknowledge(ConnectionContext context,
MessageAck ack)
|
void |
MutableBrokerFilter.acknowledge(ConnectionContext context,
MessageAck ack)
|
void |
BrokerFilter.acknowledge(ConnectionContext context,
MessageAck ack)
|
void |
TransactionBroker.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 |
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 |
Subscription.acknowledge(ConnectionContext context,
MessageAck ack)
Used when client acknowledge receipt of dispatched message. |
void |
AbstractRegion.acknowledge(ConnectionContext context,
MessageAck ack)
|
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 |
DurableTopicSubscription.acknowledge(ConnectionContext context,
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 |
PrefetchSubscription.acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference node)
Used during acknowledgment to remove the message. |
void |
DestinationFilter.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 |
Queue.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 |
ConnectionStateTracker.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 |
TransactionRecoveryListener.recover(XATransactionId xid,
Message[] addedMessages,
MessageAck[] aks)
|
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.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[] |
JournalTransactionStore.Tx.getAcks()
|
MessageAck[] |
QuickJournalTransactionStore.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 |
JournalMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
void |
QuickJournalMessageStore.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 |
JournalMessageStore.replayRemoveMessage(ConnectionContext context,
MessageAck messageAck)
|
void |
QuickJournalMessageStore.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 |
KahaMessageStore.removeMessage(ConnectionContext context,
MessageAck ack)
|
void |
KahaTopicMessageStore.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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |