org.apache.activemq.broker.region

Interface QueueMessageReference

All Superinterfaces:

MessageReference

All Known Implementing Classes:

IndirectMessageReference

public interface QueueMessageReference
extends MessageReference

Queue specific MessageReference.

Author:

fateev@amazon.com

Field Summary

Fields

Modifier and Type	Field and Description
static QueueMessageReference	NULL_MESSAGE

Method Summary

Methods

Modifier and Type	Method and Description
void	drop()
LockOwner	getLockOwner()
boolean	isAcked()
boolean	isDropped() Returns true if this message is dropped.
boolean	lock(LockOwner subscription)
void	setAcked(boolean b)
boolean	unlock()

Methods inherited from interface org.apache.activemq.broker.region.MessageReference

decrementReferenceCount, getExpiration, getGroupID, getGroupSequence, getMessage, getMessageHardRef, getMessageId, getRedeliveryCounter, getReferenceCount, getRegionDestination, getSize, getTargetConsumerId, incrementRedeliveryCounter, incrementReferenceCount, isAdvisory, isExpired, isPersistent

Field Detail

NULL_MESSAGE

static final QueueMessageReference NULL_MESSAGE

Method Detail

isAcked

boolean isAcked()

setAcked

void setAcked(boolean b)

drop

void drop()

isDropped

boolean isDropped()

Description copied from interface: MessageReference

Returns true if this message is dropped.

Specified by:

isDropped in interface MessageReference

lock

boolean lock(LockOwner subscription)

unlock

boolean unlock()

getLockOwner

LockOwner getLockOwner()