Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » [javadoc | source]
org.apache.activemq.broker.region
public class: IndirectMessageReference [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.IndirectMessageReference

All Implemented Interfaces:
    QueueMessageReference

Keeps 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.
Constructor:
 public IndirectMessageReference(Message message) 
    Parameters:
    message -
Method from org.apache.activemq.broker.region.IndirectMessageReference Summary:
decrementReferenceCount,   drop,   getExpiration,   getGroupID,   getGroupSequence,   getLockOwner,   getMessage,   getMessageHardRef,   getMessageId,   getRedeliveryCounter,   getReferenceCount,   getRegionDestination,   getSize,   getTargetConsumerId,   incrementRedeliveryCounter,   incrementReferenceCount,   isAcked,   isAdvisory,   isDropped,   isExpired,   isLocked,   isPersistent,   lock,   setAcked,   toString,   unlock
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.IndirectMessageReference Detail:
 public int decrementReferenceCount() 
 public synchronized  void drop() 
 public long getExpiration() 
 public String getGroupID() 
 public int getGroupSequence() 
 public synchronized LockOwner getLockOwner() 
 public Message getMessage() 
 public Message getMessageHardRef() 
 public MessageId getMessageId() 
 public int getRedeliveryCounter() 
 public int getReferenceCount() 
 public Destination getRegionDestination() 
 public synchronized int getSize() 
 public ConsumerId getTargetConsumerId() 
 public  void incrementRedeliveryCounter() 
 public int incrementReferenceCount() 
 public synchronized boolean isAcked() 
 public boolean isAdvisory() 
 public synchronized boolean isDropped() 
 public boolean isExpired() 
 public synchronized boolean isLocked() 
 public boolean isPersistent() 
 public boolean lock(LockOwner subscription) 
 public synchronized  void setAcked(boolean b) 
 public String toString() 
 public synchronized boolean unlock()