org.apache.qpid.server.queue
Class IncomingMessage

java.lang.Object
  extended by org.apache.qpid.server.queue.IncomingMessage
All Implemented Interfaces:
EnqueableMessage, InboundMessage, MessageContentSource, Filterable

public class IncomingMessage
extends Object
implements Filterable, InboundMessage, EnqueableMessage, MessageContentSource


Constructor Summary
IncomingMessage(org.apache.qpid.framing.abstraction.MessagePublishInfo info)
           
 
Method Summary
 int addContentBodyFrame(org.apache.qpid.framing.abstraction.ContentChunk contentChunk)
           
 boolean allContentReceived()
           
 void enqueue(ArrayList<? extends BaseQueue> queues)
           
 String getBinding()
           
 int getBodyCount()
           
 int getContent(ByteBuffer buf, int offset)
           
 org.apache.qpid.framing.abstraction.ContentChunk getContentChunk(int index)
           
 org.apache.qpid.framing.ContentHeaderBody getContentHeader()
           
 ArrayList<? extends BaseQueue> getDestinationQueues()
           
 org.apache.qpid.framing.AMQShortString getExchange()
           
 long getExpiration()
           
 AMQMessageHeader getMessageHeader()
           
 Long getMessageNumber()
           
 org.apache.qpid.framing.abstraction.MessagePublishInfo getMessagePublishInfo()
           
 int getReceivedChunkCount()
           
 String getRoutingKey()
           
 long getSize()
           
 StoredMessage<MessageMetaData> getStoredMessage()
           
 MessageMetaData headersReceived()
           
 boolean isImmediate()
           
 boolean isMandatory()
           
 boolean isPersistent()
           
 boolean isRedelivered()
           
 void route()
           
 void setContentHeaderBody(org.apache.qpid.framing.ContentHeaderBody contentHeaderBody)
           
 void setExchange(Exchange e)
           
 void setExpiration()
           
 void setStoredMessage(StoredMessage<MessageMetaData> storedMessageHandle)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

IncomingMessage

public IncomingMessage(org.apache.qpid.framing.abstraction.MessagePublishInfo info)
Method Detail

setContentHeaderBody

public void setContentHeaderBody(org.apache.qpid.framing.ContentHeaderBody contentHeaderBody)
                          throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

setExpiration

public void setExpiration()

headersReceived

public MessageMetaData headersReceived()

getDestinationQueues

public ArrayList<? extends BaseQueue> getDestinationQueues()

addContentBodyFrame

public int addContentBodyFrame(org.apache.qpid.framing.abstraction.ContentChunk contentChunk)
                        throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

allContentReceived

public boolean allContentReceived()

getExchange

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

getRoutingKey

public String getRoutingKey()
Specified by:
getRoutingKey in interface InboundMessage

getBinding

public String getBinding()

isMandatory

public boolean isMandatory()

isImmediate

public boolean isImmediate()

getContentHeader

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

getMessageHeader

public AMQMessageHeader getMessageHeader()
Specified by:
getMessageHeader in interface InboundMessage
Specified by:
getMessageHeader in interface Filterable

isPersistent

public boolean isPersistent()
Specified by:
isPersistent in interface EnqueableMessage
Specified by:
isPersistent in interface InboundMessage
Specified by:
isPersistent in interface Filterable

isRedelivered

public boolean isRedelivered()
Specified by:
isRedelivered in interface InboundMessage
Specified by:
isRedelivered in interface Filterable

getSize

public long getSize()
Specified by:
getSize in interface InboundMessage
Specified by:
getSize in interface MessageContentSource

getMessageNumber

public Long getMessageNumber()
Specified by:
getMessageNumber in interface EnqueableMessage

setExchange

public void setExchange(Exchange e)

route

public void route()

enqueue

public void enqueue(ArrayList<? extends BaseQueue> queues)

getMessagePublishInfo

public org.apache.qpid.framing.abstraction.MessagePublishInfo getMessagePublishInfo()

getExpiration

public long getExpiration()

getReceivedChunkCount

public int getReceivedChunkCount()

getBodyCount

public int getBodyCount()
                 throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

getContentChunk

public org.apache.qpid.framing.abstraction.ContentChunk getContentChunk(int index)
                                                                 throws IllegalArgumentException,
                                                                        org.apache.qpid.AMQException
Throws:
IllegalArgumentException
org.apache.qpid.AMQException

getContent

public int getContent(ByteBuffer buf,
                      int offset)
Specified by:
getContent in interface MessageContentSource

setStoredMessage

public void setStoredMessage(StoredMessage<MessageMetaData> storedMessageHandle)

getStoredMessage

public StoredMessage<MessageMetaData> getStoredMessage()


Licensed to the Apache Software Foundation