org.apache.qpid.client.message
Class UnprocessedMessage_0_8
java.lang.Object
org.apache.qpid.client.message.UnprocessedMessage
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.
Constructor Summary |
UnprocessedMessage_0_8(long deliveryId,
int consumerTag,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey,
boolean redelivered)
|
_redelivered
protected boolean _redelivered
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)
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