public class IndirectMessageReference extends Object implements QueueMessageReference
NULL_MESSAGE
Constructor and Description |
---|
IndirectMessageReference(Message message) |
Modifier and Type | Method and Description |
---|---|
boolean |
canProcessAsExpired() |
int |
decrementReferenceCount() |
void |
drop() |
boolean |
dropIfLive()
Check if the message has already been dropped before
dropping.
|
long |
getExpiration() |
String |
getGroupID() |
int |
getGroupSequence() |
LockOwner |
getLockOwner() |
Message |
getMessage() |
Message |
getMessageHardRef() |
MessageId |
getMessageId() |
int |
getRedeliveryCounter() |
int |
getReferenceCount() |
Message.MessageDestination |
getRegionDestination() |
int |
getSize() |
ConsumerId |
getTargetConsumerId() |
void |
incrementRedeliveryCounter() |
int |
incrementReferenceCount() |
boolean |
isAcked() |
boolean |
isAdvisory() |
boolean |
isDropped() |
boolean |
isExpired() |
boolean |
isLocked() |
boolean |
isPersistent() |
boolean |
lock(LockOwner subscription) |
void |
setAcked(boolean b) |
String |
toString() |
boolean |
unlock() |
public IndirectMessageReference(Message message)
message
- public Message getMessageHardRef()
getMessageHardRef
in interface MessageReference
public int getReferenceCount()
getReferenceCount
in interface MessageReference
public int incrementReferenceCount()
incrementReferenceCount
in interface MessageReference
public int decrementReferenceCount()
decrementReferenceCount
in interface MessageReference
public Message getMessage()
getMessage
in interface MessageReference
public void incrementRedeliveryCounter()
incrementRedeliveryCounter
in interface MessageReference
public boolean isDropped()
isDropped
in interface MessageReference
isDropped
in interface QueueMessageReference
public void drop()
drop
in interface QueueMessageReference
public boolean dropIfLive()
dropIfLive
in interface QueueMessageReference
public boolean lock(LockOwner subscription)
lock
in interface QueueMessageReference
public boolean unlock()
unlock
in interface QueueMessageReference
public LockOwner getLockOwner()
getLockOwner
in interface QueueMessageReference
public int getRedeliveryCounter()
getRedeliveryCounter
in interface MessageReference
public MessageId getMessageId()
getMessageId
in interface MessageReference
public Message.MessageDestination getRegionDestination()
getRegionDestination
in interface MessageReference
public boolean isPersistent()
isPersistent
in interface MessageReference
public boolean isLocked()
public boolean isAcked()
isAcked
in interface QueueMessageReference
public void setAcked(boolean b)
setAcked
in interface QueueMessageReference
public String getGroupID()
getGroupID
in interface MessageReference
public int getGroupSequence()
getGroupSequence
in interface MessageReference
public ConsumerId getTargetConsumerId()
getTargetConsumerId
in interface MessageReference
public long getExpiration()
getExpiration
in interface MessageReference
public boolean isExpired()
isExpired
in interface MessageReference
public int getSize()
getSize
in interface MessageReference
public boolean isAdvisory()
isAdvisory
in interface MessageReference
public boolean canProcessAsExpired()
canProcessAsExpired
in interface MessageReference
Copyright © 2005–2020 FuseSource, Corp.. All rights reserved.