public final class NullMessageReference extends Object implements QueueMessageReference
QueueMessageReference.NULL_MESSAGE
NULL_MESSAGE
Constructor and Description |
---|
NullMessageReference() |
Modifier and Type | Method and Description |
---|---|
int |
decrementReferenceCount() |
void |
drop() |
long |
getExpiration() |
String |
getGroupID() |
int |
getGroupSequence() |
LockOwner |
getLockOwner() |
Message |
getMessage() |
Message |
getMessageHardRef() |
MessageId |
getMessageId() |
int |
getRedeliveryCounter() |
int |
getReferenceCount() |
Destination |
getRegionDestination() |
int |
getSize() |
ConsumerId |
getTargetConsumerId() |
void |
incrementRedeliveryCounter() |
int |
incrementReferenceCount() |
boolean |
isAcked() |
boolean |
isAdvisory() |
boolean |
isDropped()
Returns true if this message is dropped.
|
boolean |
isExpired()
Returns true if this message is expired
|
boolean |
isPersistent() |
boolean |
lock(LockOwner subscription) |
void |
setAcked(boolean b) |
boolean |
unlock() |
public NullMessageReference()
public void drop()
drop
in interface QueueMessageReference
public LockOwner getLockOwner()
getLockOwner
in interface QueueMessageReference
public boolean isAcked()
isAcked
in interface QueueMessageReference
public boolean isDropped()
MessageReference
isDropped
in interface MessageReference
isDropped
in interface QueueMessageReference
public boolean lock(LockOwner subscription)
lock
in interface QueueMessageReference
public void setAcked(boolean b)
setAcked
in interface QueueMessageReference
public boolean unlock()
unlock
in interface QueueMessageReference
public int decrementReferenceCount()
decrementReferenceCount
in interface MessageReference
public long getExpiration()
getExpiration
in interface MessageReference
public String getGroupID()
getGroupID
in interface MessageReference
public int getGroupSequence()
getGroupSequence
in interface MessageReference
public Message getMessage()
getMessage
in interface MessageReference
public Message getMessageHardRef()
getMessageHardRef
in interface MessageReference
public MessageId getMessageId()
getMessageId
in interface MessageReference
public int getRedeliveryCounter()
getRedeliveryCounter
in interface MessageReference
public int getReferenceCount()
getReferenceCount
in interface MessageReference
public Destination getRegionDestination()
getRegionDestination
in interface MessageReference
public int getSize()
getSize
in interface MessageReference
public ConsumerId getTargetConsumerId()
getTargetConsumerId
in interface MessageReference
public void incrementRedeliveryCounter()
incrementRedeliveryCounter
in interface MessageReference
public int incrementReferenceCount()
incrementReferenceCount
in interface MessageReference
public boolean isExpired()
MessageReference
isExpired
in interface MessageReference
public boolean isPersistent()
isPersistent
in interface MessageReference
public boolean isAdvisory()
isAdvisory
in interface MessageReference
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.