Uses of Class org.activemq.service.MessageIdentity

Overview

Package

Class

Use

Deprecated

Index

Home >> All >> org >> activemq >> [ service overview ]

PREV NEXT

Uses of Class
org.activemq.service.MessageIdentity

Uses of MessageIdentity in org.activemq.service

Methods in org.activemq.service that return MessageIdentity

MessageIdentity Subscription.getLastMessageIdentity()
Retreives the messageIdentity of the last message sent to this Queue based Subscription

Methods in org.activemq.service with parameters of type MessageIdentity

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 Subscription.setLastMessageIdentifier(MessageIdentity messageIdentity)
          Used for a Queue based Subscription to set the last acknowledged message ID

org.activemq.message.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.

boolean MessageIdentity.equals(MessageIdentity that)


void MessageContainer.delete(MessageIdentity messageIdentity, org.activemq.message.MessageAck ack)
          Delete a message - if no

org.activemq.message.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 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.