Interface MessageReference
-
- All Known Subinterfaces:
QueueMessageReference
- All Known Implementing Classes:
ActiveMQBlobMessage,ActiveMQBytesMessage,ActiveMQMapMessage,ActiveMQMessage,ActiveMQObjectMessage,ActiveMQStreamMessage,ActiveMQTextMessage,IndirectMessageReference,Message,NullMessageReference
public interface MessageReferenceKeeps track of a message that is flowing through the Broker. This object may hold a hard reference to the message or only hold the id of the message if the message has been persisted on in a MessageStore.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleancanProcessAsExpired()intdecrementReferenceCount()longgetExpiration()StringgetGroupID()intgetGroupSequence()MessagegetMessage()MessagegetMessageHardRef()MessageIdgetMessageId()intgetRedeliveryCounter()intgetReferenceCount()Message.MessageDestinationgetRegionDestination()intgetSize()ConsumerIdgetTargetConsumerId()voidincrementRedeliveryCounter()intincrementReferenceCount()booleanisAdvisory()booleanisDropped()Returns true if this message is dropped.booleanisExpired()Returns true if this message is expiredbooleanisPersistent()
-
-
-
Method Detail
-
getMessageId
MessageId getMessageId()
-
getMessageHardRef
Message getMessageHardRef()
-
getMessage
Message getMessage()
-
isPersistent
boolean isPersistent()
-
getRegionDestination
Message.MessageDestination getRegionDestination()
-
getRedeliveryCounter
int getRedeliveryCounter()
-
incrementRedeliveryCounter
void incrementRedeliveryCounter()
-
getReferenceCount
int getReferenceCount()
-
incrementReferenceCount
int incrementReferenceCount()
-
decrementReferenceCount
int decrementReferenceCount()
-
getTargetConsumerId
ConsumerId getTargetConsumerId()
-
getSize
int getSize()
-
getExpiration
long getExpiration()
-
getGroupID
String getGroupID()
-
getGroupSequence
int getGroupSequence()
-
isExpired
boolean isExpired()
Returns true if this message is expired
-
isDropped
boolean isDropped()
Returns true if this message is dropped.
-
isAdvisory
boolean isAdvisory()
- Returns:
- true if the message is an advisory
-
canProcessAsExpired
boolean canProcessAsExpired()
-
-