Uses of Class
org.codehaus.activemq.service.MessageIdentity

Packages that use MessageIdentity
org.codehaus.activemq.message Message implementations  
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 MessageIdentity in org.codehaus.activemq.message
 

Methods in org.codehaus.activemq.message that return MessageIdentity
 MessageIdentity MessageAck.getMessageIdentity()
           
 MessageIdentity ActiveMQMessage.getJMSMessageIdentity()
           
 

Methods in org.codehaus.activemq.message with parameters of type MessageIdentity
 void ActiveMQMessage.setJMSMessageIdentity(MessageIdentity messageIdentity)
           
 

Uses of MessageIdentity in org.codehaus.activemq.service
 

Methods in org.codehaus.activemq.service that return MessageIdentity
 MessageIdentity Subscription.getLastMessageIdentity()
          Retreives the messageIdentity of the last message sent to this Queue based Subscription
 MessageIdentity MessageContainer.addMessage(ActiveMQMessage msg)
          Add an ActiveMQMessage to the message container
 

Methods in org.codehaus.activemq.service with parameters of type MessageIdentity
 void Subscription.setLastMessageIdentifier(MessageIdentity messageIdentity)
          Used for a Queue based Subscription to set the last acknowledged message ID
 boolean MessageIdentity.equals(MessageIdentity that)
           
 void TopicMessageContainer.setLastAcknowledgedMessageID(Subscription subscription, MessageIdentity messageIdentity)
          Sets the last acknowleged message ID for the given subscriber in this container so that if we shut down and recover we know where to start replaying messages from.
 void MessageContainer.delete(MessageIdentity messageIdentity, MessageAck ack)
          Delete a message - if no
 ActiveMQMessage MessageContainer.getMessage(MessageIdentity messageIdentity)
          Return the ActiveMQMessage that matches the Id
 void MessageContainer.registerMessageInterest(MessageIdentity messageIdentity)
          Register that a consumer will be interested in this message
 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
 boolean MessageContainer.containsMessage(MessageIdentity messageIdentity)
          Returns whether or not this container contains the given message identity which provides an optimisation over getMessage() where the message does not need to be loaded.
 ActiveMQMessage QueueMessageContainer.peekNext(MessageIdentity messageIdentity)
          Used for browsing a MessageContainer this returns the next message in the container after the messageId
 void QueueMessageContainer.returnMessage(MessageIdentity messageIdentity)
          After a poll() on the Container, if a message can't be dispatched, it is returned
 void QueueMessageContainer.recoverMessageToBeDelivered(MessageIdentity messageIdentity)
          Invoked during the recovery to add the given message to the end of the messages to be delivered.
 

Uses of MessageIdentity in org.codehaus.activemq.service.boundedvm
 

Methods in org.codehaus.activemq.service.boundedvm that return MessageIdentity
 MessageIdentity TransientTopicBoundedMessageContainer.addMessage(ActiveMQMessage msg)
           
 MessageIdentity TransientQueueBoundedMessageContainer.addMessage(ActiveMQMessage msg)
           
 

Methods in org.codehaus.activemq.service.boundedvm with parameters of type MessageIdentity
 void TransientTopicBoundedMessageContainer.delete(MessageIdentity messageIdentity, MessageAck ack)
           
 ActiveMQMessage TransientTopicBoundedMessageContainer.getMessage(MessageIdentity messageIdentity)
           
 void TransientTopicBoundedMessageContainer.registerMessageInterest(MessageIdentity messageIdentity)
           
 void TransientTopicBoundedMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity, MessageAck ack)
           
 boolean TransientTopicBoundedMessageContainer.containsMessage(MessageIdentity messageIdentity)
           
 void TransientQueueBoundedMessageContainer.delete(MessageIdentity messageIdentity, MessageAck ack)
           
 ActiveMQMessage TransientQueueBoundedMessageContainer.getMessage(MessageIdentity messageIdentity)
           
 void TransientQueueBoundedMessageContainer.registerMessageInterest(MessageIdentity messageIdentity)
           
 void TransientQueueBoundedMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity, MessageAck ack)
           
 boolean TransientQueueBoundedMessageContainer.containsMessage(MessageIdentity messageIdentity)
           
 

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

Methods in org.codehaus.activemq.service.impl that return MessageIdentity
 MessageIdentity MessagePointer.getMessageIdentity()
           
 MessageIdentity SubscriptionImpl.getLastMessageIdentity()
           
 MessageIdentity DurableTopicMessageContainer.addMessage(ActiveMQMessage message)
           
 MessageIdentity DurableQueueMessageContainer.addMessage(ActiveMQMessage message)
           
 

Methods in org.codehaus.activemq.service.impl with parameters of type MessageIdentity
 void MessagePointer.setMessageIdentity(MessageIdentity messageIdentity)
           
 void SubscriptionImpl.setLastMessageIdentifier(MessageIdentity messageIdentity)
           
 void DurableTopicMessageContainer.delete(MessageIdentity messageID, MessageAck ack)
           
 boolean DurableTopicMessageContainer.containsMessage(MessageIdentity messageIdentity)
           
 ActiveMQMessage DurableTopicMessageContainer.getMessage(MessageIdentity messageID)
           
 void DurableTopicMessageContainer.registerMessageInterest(MessageIdentity messageIdentity)
           
 void DurableTopicMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity, MessageAck ack)
           
 void DurableTopicMessageContainer.setLastAcknowledgedMessageID(Subscription subscription, MessageIdentity messageIdentity)
           
 void DurableQueueMessageContainer.delete(MessageIdentity messageID, MessageAck ack)
           
 ActiveMQMessage DurableQueueMessageContainer.getMessage(MessageIdentity messageID)
           
 boolean DurableQueueMessageContainer.containsMessage(MessageIdentity messageIdentity)
           
 void DurableQueueMessageContainer.registerMessageInterest(MessageIdentity messageIdentity)
          Does nothing since when we receive an acknowledgement on a queue we can delete the message
 void DurableQueueMessageContainer.unregisterMessageInterest(MessageIdentity messageIdentity, MessageAck ack)
          Does nothing since when we receive an acknowledgement on a queue we can delete the message
 ActiveMQMessage DurableQueueMessageContainer.peekNext(MessageIdentity messageID)
           
 void DurableQueueMessageContainer.returnMessage(MessageIdentity messageIdentity)
           
 void DurableQueueMessageContainer.recoverMessageToBeDelivered(MessageIdentity messageIdentity)
           
 

Constructors in org.codehaus.activemq.service.impl with parameters of type MessageIdentity
MessagePointer(MessageContainer container, MessageIdentity messageIdentity)
          Create a message ptr
 

Uses of MessageIdentity in org.codehaus.activemq.store
 

Methods in org.codehaus.activemq.store that return MessageIdentity
 MessageIdentity TopicMessageStore.getLastestMessageIdentity()
          Returns the last message identity that was delivered on this container which can then be used as a checkpoint so that when new durable consumers start, we know where to checkpoint their subscriptions.
 MessageIdentity MessageStore.addMessage(ActiveMQMessage message)
          Adds a message to the message store
 

Methods in org.codehaus.activemq.store with parameters of type MessageIdentity
 void TopicMessageStore.incrementMessageCount(MessageIdentity messageId)
          Increments the reference count of the message ID as its been dispatched to another subscriber.
 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 TopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
          Stores the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint
 void TopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
          For the new subcription find the last acknowledged message ID and then find any new messages since then and dispatch them to the subscription.
 ActiveMQMessage MessageStore.getMessage(MessageIdentity identity)
          Looks up a message using either the String messageID or the messageNumber.
 void MessageStore.removeMessage(MessageIdentity identity, MessageAck ack)
           
 

Uses of MessageIdentity in org.codehaus.activemq.store.bdb
 

Methods in org.codehaus.activemq.store.bdb that return MessageIdentity
 MessageIdentity BDbTopicMessageStore.getLastestMessageIdentity()
           
 MessageIdentity BDbMessageStore.addMessage(ActiveMQMessage message)
           
 

Methods in org.codehaus.activemq.store.bdb with parameters of type MessageIdentity
 void BDbTopicMessageStore.incrementMessageCount(MessageIdentity messageId)
           
 void BDbTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity, MessageAck ack)
           
 void BDbTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void BDbTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
protected  com.sleepycat.je.DatabaseEntry BDbTopicMessageStore.getLastAcknowledgedMessageID(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
protected  com.sleepycat.je.DatabaseEntry BDbTopicMessageStore.doSetLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 ActiveMQMessage BDbMessageStore.getMessage(MessageIdentity identity)
           
 void BDbMessageStore.removeMessage(MessageIdentity identity, MessageAck ack)
           
protected  com.sleepycat.je.DatabaseEntry BDbMessageStore.getSequenceNumberKey(MessageIdentity identity)
          Returns the sequence number key for the given message identity.
 

Uses of MessageIdentity in org.codehaus.activemq.store.bdbn
 

Methods in org.codehaus.activemq.store.bdbn that return MessageIdentity
 MessageIdentity BDbTopicMessageStore.getLastestMessageIdentity()
           
 MessageIdentity BDbMessageStore.addMessage(ActiveMQMessage message)
           
 

Methods in org.codehaus.activemq.store.bdbn with parameters of type MessageIdentity
 void BDbTopicMessageStore.incrementMessageCount(MessageIdentity messageId)
           
 void BDbTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity, MessageAck ack)
           
 void BDbTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void BDbTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 ActiveMQMessage BDbMessageStore.getMessage(MessageIdentity identity)
           
 void BDbMessageStore.removeMessage(MessageIdentity identity, MessageAck ack)
           
 

Uses of MessageIdentity in org.codehaus.activemq.store.cache
 

Methods in org.codehaus.activemq.store.cache that return MessageIdentity
 MessageIdentity CacheTopicMessageStore.getLastestMessageIdentity()
           
 MessageIdentity CacheMessageStore.addMessage(ActiveMQMessage message)
          Add the meessage to the long term store and cache it.
 

Methods in org.codehaus.activemq.store.cache with parameters of type MessageIdentity
 void CacheTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void CacheTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 void CacheTopicMessageStore.incrementMessageCount(MessageIdentity messageId)
           
 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.
 ActiveMQMessage CacheMessageStore.getMessage(MessageIdentity identity)
          Return the message from the cache or go to the longTermStore if it is not in there.
 

Uses of MessageIdentity in org.codehaus.activemq.store.howl
 

Methods in org.codehaus.activemq.store.howl that return MessageIdentity
 MessageIdentity HowlMessageStore.addMessage(ActiveMQMessage message)
          This method is synchronized to ensure that only 1 thread can write to the log and cache and possibly checkpoint at once, to preserve order across the transaction log, cache and checkpointStore.
 

Methods in org.codehaus.activemq.store.howl with parameters of type MessageIdentity
 ActiveMQMessage HowlMessageStore.getMessage(MessageIdentity identity)
          Lets ensure that readers don't block writers so there only synchronization on the cache and checkpointStore.
 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 MessageIdentity in org.codehaus.activemq.store.jdbc
 

Methods in org.codehaus.activemq.store.jdbc that return MessageIdentity
 MessageIdentity JDBCTopicMessageStore.getLastestMessageIdentity()
           
 MessageIdentity JDBCMessageStore.addMessage(ActiveMQMessage message)
           
 

Methods in org.codehaus.activemq.store.jdbc with parameters of type MessageIdentity
 void JDBCTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void JDBCTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 void JDBCTopicMessageStore.incrementMessageCount(MessageIdentity messageId)
           
 void JDBCTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity, MessageAck ack)
           
 ActiveMQMessage JDBCMessageStore.getMessage(MessageIdentity identity)
           
 void JDBCMessageStore.removeMessage(MessageIdentity identity, MessageAck ack)
           
 

Uses of MessageIdentity in org.codehaus.activemq.store.jdbm
 

Methods in org.codehaus.activemq.store.jdbm that return MessageIdentity
 MessageIdentity JdbmTopicMessageStore.getLastestMessageIdentity()
           
protected  MessageIdentity JdbmTopicMessageStore.getLastAcknowledgedMessageIdentity(Subscription subscription)
           
 MessageIdentity JdbmMessageStore.addMessage(ActiveMQMessage message)
           
 

Methods in org.codehaus.activemq.store.jdbm with parameters of type MessageIdentity
 void JdbmTopicMessageStore.incrementMessageCount(MessageIdentity messageId)
           
 void JdbmTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity, MessageAck ack)
           
 void JdbmTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void JdbmTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 ActiveMQMessage JdbmMessageStore.getMessage(MessageIdentity identity)
           
 void JdbmMessageStore.removeMessage(MessageIdentity identity, MessageAck ack)
           
 

Uses of MessageIdentity in org.codehaus.activemq.store.journal
 

Methods in org.codehaus.activemq.store.journal that return MessageIdentity
 MessageIdentity JournalMessageStore.addMessage(ActiveMQMessage message)
          Not synchronized since the Journal has better throughput if you increase the number of conncurrent writes that it is doing.
 

Methods in org.codehaus.activemq.store.journal with parameters of type MessageIdentity
 void JournalMessageStore.removeMessage(MessageIdentity identity, MessageAck ack)
           
 ActiveMQMessage JournalMessageStore.getMessage(MessageIdentity identity)
           
 

Uses of MessageIdentity in org.codehaus.activemq.store.vm
 

Methods in org.codehaus.activemq.store.vm that return MessageIdentity
 MessageIdentity VMTopicMessageStore.getLastestMessageIdentity()
           
 MessageIdentity VMMessageStore.addMessage(ActiveMQMessage message)
           
 

Methods in org.codehaus.activemq.store.vm with parameters of type MessageIdentity
 void VMTopicMessageStore.incrementMessageCount(MessageIdentity messageId)
           
 void VMTopicMessageStore.decrementMessageCountAndMaybeDelete(MessageIdentity messageIdentity, MessageAck ack)
           
 void VMTopicMessageStore.setLastAcknowledgedMessageIdentity(Subscription subscription, MessageIdentity messageIdentity)
           
 void VMTopicMessageStore.recoverSubscription(Subscription subscription, MessageIdentity lastDispatchedMessage)
           
 ActiveMQMessage VMMessageStore.getMessage(MessageIdentity identity)
           
 void VMMessageStore.removeMessage(MessageIdentity identity, MessageAck ack)
           
 



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