org.apache.qpid.client.message
Class UnprocessedMessage_0_8

java.lang.Object
  extended by org.apache.qpid.client.message.UnprocessedMessage
      extended by org.apache.qpid.client.message.UnprocessedMessage_0_8
All Implemented Interfaces:
AMQSession.Dispatchable
Direct Known Subclasses:
ReturnMessage

public class UnprocessedMessage_0_8
extends UnprocessedMessage

This class contains everything needed to process a JMS message. It assembles the deliver body, the content header and the content body/ies. Note that the actual work of creating a JMS message for the client code's use is done outside of the MINA dispatcher thread in order to minimise the amount of work done in the MINA dispatcher thread.


Field Summary
protected  boolean _redelivered
           
 
Constructor Summary
UnprocessedMessage_0_8(long deliveryId, int consumerTag, org.apache.qpid.framing.AMQShortString exchange, org.apache.qpid.framing.AMQShortString routingKey, boolean redelivered)
           
 
Method Summary
 List<org.apache.qpid.framing.ContentBody> getBodies()
           
 org.apache.qpid.framing.ContentHeaderBody getContentHeader()
           
 org.apache.qpid.framing.BasicDeliverBody getDeliverBody()
           
 long getDeliveryTag()
           
 org.apache.qpid.framing.AMQShortString getExchange()
           
 org.apache.qpid.framing.AMQShortString getRoutingKey()
           
 boolean isAllBodyDataReceived()
           
 boolean isRedelivered()
           
 void receiveBody(org.apache.qpid.framing.ContentBody body)
           
 void setContentHeader(org.apache.qpid.framing.ContentHeaderBody contentHeader)
           
 void setMethodBody(org.apache.qpid.framing.BasicDeliverBody deliverBody)
           
 String toString()
           
 
Methods inherited from class org.apache.qpid.client.message.UnprocessedMessage
dispatch, getConsumerTag
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

_redelivered

protected boolean _redelivered
Constructor Detail

UnprocessedMessage_0_8

public UnprocessedMessage_0_8(long deliveryId,
                              int consumerTag,
                              org.apache.qpid.framing.AMQShortString exchange,
                              org.apache.qpid.framing.AMQShortString routingKey,
                              boolean redelivered)
Method Detail

getExchange

public org.apache.qpid.framing.AMQShortString getExchange()

getRoutingKey

public org.apache.qpid.framing.AMQShortString getRoutingKey()

getDeliveryTag

public long getDeliveryTag()
Specified by:
getDeliveryTag in class UnprocessedMessage

isRedelivered

public boolean isRedelivered()

receiveBody

public void receiveBody(org.apache.qpid.framing.ContentBody body)

setMethodBody

public void setMethodBody(org.apache.qpid.framing.BasicDeliverBody deliverBody)

setContentHeader

public void setContentHeader(org.apache.qpid.framing.ContentHeaderBody contentHeader)

isAllBodyDataReceived

public boolean isAllBodyDataReceived()

getDeliverBody

public org.apache.qpid.framing.BasicDeliverBody getDeliverBody()

getContentHeader

public org.apache.qpid.framing.ContentHeaderBody getContentHeader()

getBodies

public List<org.apache.qpid.framing.ContentBody> getBodies()

toString

public String toString()
Overrides:
toString in class Object


Licensed to the Apache Software Foundation