Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

## 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.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.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.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` | `BrokerContainer.acknowledgeTransactedMessage(BrokerClient client, java.lang.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` | `BrokerConnector.acknowledgeTransactedMessage(BrokerClient client, java.lang.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` | `Broker.acknowledgeMessage(BrokerClient client, MessageAck ack)` Acknowledge consumption of a message by the Message Consumer
`void` | `Broker.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)` Acknowledge 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, java.lang.String transactionId, MessageAck ack)` Acknowledge consumption of a message within a transaction
`void` | `DefaultBroker.redeliverMessage(BrokerClient client, MessageAck ack)`
`void` | `BrokerContainerImpl.acknowledgeTransactedMessage(BrokerClient client, java.lang.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, java.lang.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` | `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, java.lang.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, java.lang.String transactionId, MessageAck ack)`
`void` | `TransientTopicBoundedMessageManager.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` | `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` | `QueueMessageContainerManager.acknowledgeMessage(BrokerClient client, MessageAck ack)` Acknowledge a message as being read and consumed by the Consumer
`void` | `QueueMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)`
`void` | `QueueMessageContainerManager.redeliverMessage(BrokerClient client, MessageAck ack)`
`void` | `ProxyMessageContainerManager.acknowledgeMessage(BrokerClient client, MessageAck ack)`
`void` | `ProxyMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)`
`void` | `ProxyMessageContainerManager.redeliverMessage(BrokerClient client, MessageAck ack)`
`void` | `MessagePointer.delete(MessageAck ack)` Notify the container it should delete the message
`void` | `DurableTopicSubscription.messageConsumed(MessageAck ack)`
`void` | `DurableTopicSubscription.redeliverMessage(MessageContainer container, MessageAck ack)`
`void` | `DurableTopicMessageContainerManager.acknowledgeMessage(BrokerClient client, MessageAck ack)` Acknowledge a message as being read and consumed byh the Consumer
`void` | `DurableTopicMessageContainerManager.acknowledgeTransactedMessage(BrokerClient client, java.lang.String transactionId, MessageAck ack)`
`void` | `DurableTopicMessageContainerManager.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

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

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

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