Uses of Class
org.codehaus.activemq.message.MessageAck

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

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

Uses of MessageAck in org.codehaus.activemq.service
 

Methods in org.codehaus.activemq.service with parameters of type MessageAck
 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 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 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 TransientQueueBoundedMessageContainer.delete(MessageIdentity messageIdentity, MessageAck ack)
           
 void TransientQueueBoundedMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity, 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)
           
 

Uses of MessageAck in org.codehaus.activemq.service.impl
 

Methods in org.codehaus.activemq.service.impl with parameters of type MessageAck
 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)
           
 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 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 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 DurableTopicMessageContainer.delete(MessageIdentity messageID, MessageAck ack)
           
 void DurableTopicMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity, MessageAck ack)
           
 

Constructors in org.codehaus.activemq.service.impl with parameters of type MessageAck
MessageAckTransactionTask(BrokerClient brokerClient, MessageAck ack)
           
RedeliverMessageTransactionTask(BrokerClient brokerClient, MessageAck ack)
           
 

Uses of MessageAck in org.codehaus.activemq.store
 

Methods in org.codehaus.activemq.store with parameters of type MessageAck
 void MessageStore.removeMessage(MessageIdentity identity, MessageAck ack)
          Removes a message from the message store.
 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)
 

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



Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.