Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.service.impl
Class MessagePointer  view MessagePointer download MessagePointer.java

java.lang.Object
  extended byorg.activemq.service.impl.MessagePointer

class MessagePointer
extends java.lang.Object

An entry for a message to be dispatched

Version:
$Revision: 1.1.1.1 $

Field Summary
private  org.activemq.service.MessageContainer container
           
private  boolean deleted
           
private  boolean dispatched
           
private static org.apache.commons.logging.Log log
           
private  org.activemq.service.MessageIdentity messageIdentity
           
private  boolean read
           
private  boolean redelivered
           
 
Constructor Summary
MessagePointer(org.activemq.service.MessageContainer container, org.activemq.message.ActiveMQMessage message)
          Create a message ptr
MessagePointer(MessagePointer copy)
           
 
Method Summary
 void clear()
          Simply remove the interest in the message
 void delete(org.activemq.message.MessageAck ack)
          Notify the container it should delete the message
 org.activemq.service.MessageContainer getContainer()
           
 org.activemq.service.MessageIdentity getMessageIdentity()
           
 boolean isDeleted()
           
 boolean isDispatched()
           
 boolean isRead()
           
 boolean isRedelivered()
           
 void reset()
          Reset default states for this MessagePointer
 void setContainer(org.activemq.service.MessageContainer container)
           
 void setDispatched(boolean dispatched)
           
 void setMessageIdentity(org.activemq.service.MessageIdentity messageIdentity)
           
 void setRead(boolean read)
           
 void setRedelivered(boolean redelivered)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

private static final org.apache.commons.logging.Log log

container

private org.activemq.service.MessageContainer container

messageIdentity

private org.activemq.service.MessageIdentity messageIdentity

dispatched

private boolean dispatched

read

private boolean read

redelivered

private boolean redelivered

deleted

private boolean deleted
Constructor Detail

MessagePointer

public MessagePointer(MessagePointer copy)
               throws javax.jms.JMSException

MessagePointer

public MessagePointer(org.activemq.service.MessageContainer container,
                      org.activemq.message.ActiveMQMessage message)
               throws javax.jms.JMSException
Create a message ptr

Method Detail

reset

public void reset()
Reset default states for this MessagePointer


clear

public void clear()
           throws javax.jms.JMSException
Simply remove the interest in the message


delete

public void delete(org.activemq.message.MessageAck ack)
            throws javax.jms.JMSException
Notify the container it should delete the message


getContainer

public org.activemq.service.MessageContainer getContainer()

setContainer

public void setContainer(org.activemq.service.MessageContainer container)

isDispatched

public boolean isDispatched()

isDeleted

public boolean isDeleted()

setDispatched

public void setDispatched(boolean dispatched)

isRead

public boolean isRead()

setRead

public void setRead(boolean read)

getMessageIdentity

public org.activemq.service.MessageIdentity getMessageIdentity()

setMessageIdentity

public void setMessageIdentity(org.activemq.service.MessageIdentity messageIdentity)

isRedelivered

public boolean isRedelivered()

setRedelivered

public void setRedelivered(boolean redelivered)
                    throws javax.jms.JMSException