|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MessageAck | |
org.codehaus.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.codehaus.activemq.broker.impl | The default implementation of the JMS Broker |
org.codehaus.activemq.service | The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager |
org.codehaus.activemq.service.boundedvm | |
org.codehaus.activemq.service.impl | Default implementations of the services |
org.codehaus.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.codehaus.activemq.store.bdb | Message persistence implemented using Berkeley DB Java Edition |
org.codehaus.activemq.store.bdbn | Message persistence implemented using Berkeley DB, native C version |
org.codehaus.activemq.store.cache | |
org.codehaus.activemq.store.howl | Message persistence using a high performance transaction log via implemented using Howl whichi is used for short term persistence with longer term storage being used at checkpoints. |
org.codehaus.activemq.store.jdbc | Message persistence implemented using JDBC |
org.codehaus.activemq.store.jdbm | Message persistence implemented using JDBM which is the default persistence mechanism shipped with Geronimo (due to its BSD licence) |
org.codehaus.activemq.store.journal | Message persistence using a high performance transaction log via the Journal interface. |
org.codehaus.activemq.store.vm | VM based implementation of message persistence |
Uses of MessageAck in org.codehaus.activemq.broker |
Methods in org.codehaus.activemq.broker with parameters of type MessageAck | |
void |
Broker.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge positively or negatively, the consumption of a message by the Message Consumer |
void |
Broker.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
Acknowledge positively or negatively, the consumption of a message within a transaction |
void |
Broker.redeliverMessage(BrokerClient client,
MessageAck ack)
Called after a rollback of a JMS transaction to redeliver the message to the consumers dispatch queue |
void |
BrokerConnector.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
Acknowledge receipt of a message within a transaction context |
void |
BrokerConnector.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
void |
BrokerContainer.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
Acknowledge receipt of a message within a transaction context |
void |
BrokerContainer.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
Uses of MessageAck in org.codehaus.activemq.broker.impl |
Methods in org.codehaus.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 |
DefaultBroker.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
Acknowledge consumption of a message within a transaction |
void |
DefaultBroker.redeliverMessage(BrokerClient client,
MessageAck ack)
|
void |
BrokerContainerImpl.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
Acknowledge receipt of a message within a transaction context |
void |
BrokerContainerImpl.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
void |
BrokerConnectorImpl.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
Acknowledge receipt of a message within a transaction context |
void |
BrokerConnectorImpl.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
Uses of MessageAck in org.codehaus.activemq.service |
Methods in org.codehaus.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 |
MessageContainerManager.redeliverMessage(BrokerClient client,
MessageAck ack)
Called after a rollback of a JMS transaction to redeliver the message to the consumers dispatch queue |
void |
MessageContainerManager.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
This is a hook to notify the dispatcher for the clients subscription that we have acknowledged a message within a transaction but before the commit - so the message is not really being acknowledged here but this method is intended to be a hook to let the dispatcher know that we can now send another message to the client. |
void |
Subscription.messageConsumed(MessageAck ack)
Indicates a message has been delivered to a MessageConsumer which is typically called for topic based subscriptions |
void |
Subscription.redeliverMessage(MessageContainer container,
MessageAck ack)
Forces the given message to be redelivered |
void |
Subscription.onAcknowledgeTransactedMessageBeforeCommit(MessageAck ack)
We have not yet committed and so the message acknowledgement has not really occurred yet but we need to let the dispatcher know that we can commence dispatching more messages to the client. |
void |
MessageContainer.delete(MessageIdentity messageIdentity,
MessageAck ack)
Delete a message - if no |
void |
MessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity,
MessageAck ack)
A message consumer calls this when it's no longer interested in a message so that we know when we can delete (or archive) it |
Uses of MessageAck in org.codehaus.activemq.service.boundedvm |
Methods in org.codehaus.activemq.service.boundedvm with parameters of type MessageAck | |
void |
TransientTopicBoundedMessageManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
|
void |
TransientTopicBoundedMessageManager.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
|
void |
TransientTopicBoundedMessageManager.redeliverMessage(BrokerClient client,
MessageAck ack)
|
void |
TransientTopicBoundedMessageContainer.delete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
TransientTopicBoundedMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
TransientQueueBoundedMessageManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
|
void |
TransientQueueBoundedMessageManager.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
|
void |
TransientQueueBoundedMessageManager.redeliverMessage(BrokerClient client,
MessageAck ack)
|
void |
TransientQueueBoundedMessageContainer.delete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
TransientQueueBoundedMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity,
MessageAck ack)
|
Uses of MessageAck in org.codehaus.activemq.service.impl |
Methods in org.codehaus.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 |
DurableQueueMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
|
void |
DurableQueueMessageContainerManager.redeliverMessage(BrokerClient client,
MessageAck ack)
|
void |
MessagePointer.delete(MessageAck ack)
Notify the container it should delete the message |
void |
SubscriptionImpl.messageConsumed(MessageAck ack)
Indicates a message has been delivered to a MessageConsumer |
void |
SubscriptionImpl.onAcknowledgeTransactedMessageBeforeCommit(MessageAck ack)
|
void |
SubscriptionImpl.redeliverMessage(MessageContainer container,
MessageAck ack)
|
protected void |
SubscriptionImpl.doMessageConsume(MessageAck ack,
boolean remove)
Consume a message. |
void |
DurableTopicSubscription.messageConsumed(MessageAck ack)
|
void |
DurableTopicSubscription.redeliverMessage(MessageContainer container,
MessageAck ack)
|
void |
ProxyMessageContainerManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
|
void |
ProxyMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
|
void |
ProxyMessageContainerManager.redeliverMessage(BrokerClient client,
MessageAck ack)
|
void |
DurableTopicMessageContainer.delete(MessageIdentity messageID,
MessageAck ack)
|
void |
DurableTopicMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
DurableQueueMessageContainer.delete(MessageIdentity messageID,
MessageAck ack)
|
void |
DurableQueueMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity,
MessageAck ack)
Does nothing since when we receive an acknowledgement on a queue we can delete the message |
void |
DurableTopicMessageContainerManager.acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge a message as being read and consumed byh the Consumer |
void |
DurableTopicMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
|
void |
DurableTopicMessageContainerManager.redeliverMessage(BrokerClient client,
MessageAck ack)
|
Constructors in org.codehaus.activemq.service.impl with parameters of type MessageAck | |
RedeliverMessageTransactionTask(BrokerClient brokerClient,
MessageAck ack)
|
|
MessageAckTransactionTask(BrokerClient brokerClient,
MessageAck ack)
|
Uses of MessageAck in org.codehaus.activemq.store |
Methods in org.codehaus.activemq.store with parameters of type MessageAck | |
void |
TopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity,
MessageAck ack)
Decrement the reference count of this message ID and if there are no more references then delete the message from persistent store (or maybe archive it off somewhere) |
void |
MessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
|
Uses of MessageAck in org.codehaus.activemq.store.bdb |
Methods in org.codehaus.activemq.store.bdb with parameters of type MessageAck | |
void |
BDbTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
BDbMessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
|
Uses of MessageAck in org.codehaus.activemq.store.bdbn |
Methods in org.codehaus.activemq.store.bdbn with parameters of type MessageAck | |
void |
BDbTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
BDbMessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
|
Uses of MessageAck in org.codehaus.activemq.store.cache |
Methods in org.codehaus.activemq.store.cache with parameters of type MessageAck | |
void |
CacheTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
CacheMessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
Remove the meessage to the long term store and remove it from the cache. |
Uses of MessageAck in org.codehaus.activemq.store.howl |
Methods in org.codehaus.activemq.store.howl with parameters of type MessageAck | |
void |
HowlMessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
Removes can be done in any order so we only synchronize on the cache and checkpointStore |
Uses of MessageAck in org.codehaus.activemq.store.jdbc |
Methods in org.codehaus.activemq.store.jdbc with parameters of type MessageAck | |
void |
JDBCTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
JDBCMessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
|
Uses of MessageAck in org.codehaus.activemq.store.jdbm |
Methods in org.codehaus.activemq.store.jdbm with parameters of type MessageAck | |
void |
JdbmTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
JdbmMessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
|
Uses of MessageAck in org.codehaus.activemq.store.journal |
Methods in org.codehaus.activemq.store.journal with parameters of type MessageAck | |
void |
JournalMessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
|
Uses of MessageAck in org.codehaus.activemq.store.vm |
Methods in org.codehaus.activemq.store.vm with parameters of type MessageAck | |
void |
VMTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity,
MessageAck ack)
|
void |
VMMessageStore.removeMessage(MessageIdentity identity,
MessageAck ack)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |