org.apache.qpid.client.message
Class UnprocessedMessage

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

public abstract class UnprocessedMessage
extends Object
implements AMQSession.Dispatchable

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(int consumerTag)
           
 
Method Summary
 void dispatch(AMQSession ssn)
           
 int getConsumerTag()
           
abstract  long getDeliveryTag()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

UnprocessedMessage

public UnprocessedMessage(int consumerTag)
Method Detail

getDeliveryTag

public abstract long getDeliveryTag()

getConsumerTag

public int getConsumerTag()

dispatch

public void dispatch(AMQSession ssn)
Specified by:
dispatch in interface AMQSession.Dispatchable


Licensed to the Apache Software Foundation