org.apache.qpid.server.queue
Class IncomingMessage
java.lang.Object
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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
IncomingMessage
public IncomingMessage(org.apache.qpid.framing.abstraction.MessagePublishInfo info)
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