|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |