|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MessageAck | |
---|---|
org.activemq.broker | The API for the JMS Broker which is the server side of a JMS network though it may be deployed inside a client in peer style networks. |
org.activemq.broker.impl | The default implementation of the JMS Broker |
org.activemq.service | The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager |
org.activemq.service.boundedvm | |
org.activemq.service.impl | Default implementations of the services |
org.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.activemq.store.cache | |
org.activemq.store.jdbc | Message persistence implemented using JDBC |
org.activemq.store.journal | Message persistence using a high performance transaction log via the Journal interface. |
org.activemq.store.vm | VM based implementation of message persistence |
Uses of MessageAck in org.activemq.broker |
---|
Methods in org.activemq.broker with parameters of type MessageAck | |
---|---|
void |
BrokerContainer.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
void |
Broker.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge positively or negatively, the consumption of a message by the Message Consumer |
void |
BrokerConnector.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
Uses of MessageAck in org.activemq.broker.impl |
---|
Methods in org.activemq.broker.impl with parameters of type MessageAck | |
---|---|
void |
DefaultBroker.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge consumption of a message by the Message Consumer |
void |
BrokerContainerImpl.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
void |
BrokerConnectorImpl.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
Uses of MessageAck in org.activemq.service |
---|
Methods in org.activemq.service with parameters of type MessageAck | |
---|---|
void |
MessageContainerManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge a message as being read and consumed by the Consumer |
void |
MessageContainer.delete(MessageIdentity messageIdentity,
MessageAck ack)
Delete a message - if no |
void |
Subscription.messageConsumed(MessageAck ack)
Indicates a message has been delivered to a MessageConsumer which is typically called for topic based subscriptions |
Uses of MessageAck in org.activemq.service.boundedvm |
---|
Methods in org.activemq.service.boundedvm with parameters of type MessageAck | |
---|---|
void |
TransientQueueBoundedMessageManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
|
void |
DurableQueueBoundedMessageManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
|
void |
TransientTopicBoundedMessageManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
|
void |
TransientQueueBoundedMessageContainer.delete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
TransientTopicBoundedMessageContainer.delete(MessageIdentity messageIdentity,
MessageAck ack)
|
Uses of MessageAck in org.activemq.service.impl |
---|
Methods in org.activemq.service.impl with parameters of type MessageAck | |
---|---|
void |
DurableQueueMessageContainerManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge a message as being read and consumed by the Consumer |
void |
DurableTopicMessageContainerManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge a message as being read and consumed byh the Consumer |
void |
ProxyMessageContainerManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
|
void |
DurableQueueMessageContainer.delete(MessageIdentity messageID,
MessageAck ack)
|
void |
DurableTopicMessageContainer.delete(MessageIdentity messageID,
MessageAck ack)
|
void |
DurableTopicSubscription.messageConsumed(MessageAck ack)
|
void |
SubscriptionImpl.messageConsumed(MessageAck ack)
Indicates a message has been delivered to a MessageConsumer |
Uses of MessageAck in org.activemq.store |
---|
Methods in org.activemq.store with parameters of type MessageAck | |
---|---|
void |
TransactionStore.RecoveryListener.recover(ActiveMQXid xid,
ActiveMQMessage[] addedMessages,
MessageAck[] aks)
|
void |
MessageStore.removeMessage(MessageAck ack)
Removes a message from the message store. |
void |
ProxyMessageStore.removeMessage(MessageAck ack)
|
void |
ProxyTopicMessageStore.removeMessage(MessageAck ack)
|
Uses of MessageAck in org.activemq.store.cache |
---|
Methods in org.activemq.store.cache with parameters of type MessageAck | |
---|---|
void |
CacheMessageStore.removeMessage(MessageAck ack)
Remove the meessage to the long term store and remove it from the cache. |
Uses of MessageAck in org.activemq.store.jdbc |
---|
Methods in org.activemq.store.jdbc with parameters of type MessageAck | |
---|---|
void |
JDBCMessageStore.removeMessage(MessageAck ack)
|
Uses of MessageAck in org.activemq.store.journal |
---|
Methods in org.activemq.store.journal that return MessageAck | |
---|---|
MessageAck[] |
JournalTransactionStore.Tx.getAcks()
|
MessageAck |
JournalTransactionStore.RemoveMessageCommand.getMessageAck()
|
Methods in org.activemq.store.journal with parameters of type MessageAck | |
---|---|
void |
JournalTransactionStore.Tx.add(JournalMessageStore store,
MessageAck ack)
|
void |
JournalTransactionStore.removeMessage(JournalMessageStore store,
MessageAck ack,
org.activeio.journal.RecordLocation location)
|
void |
JournalMessageStore.removeMessage(MessageAck ack)
|
void |
JournalMessageStore.replayRemoveMessage(MessageAck ack)
|
Uses of MessageAck in org.activemq.store.vm |
---|
Methods in org.activemq.store.vm that return MessageAck | |
---|---|
MessageAck[] |
VMTransactionStore.Tx.getAcks()
|
MessageAck |
VMTransactionStore.RemoveMessageCommand.getMessageAck()
|
Methods in org.activemq.store.vm with parameters of type MessageAck | |
---|---|
void |
VMMessageStore.removeMessage(MessageAck ack)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |