|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.qpid.server.queue.AMQMessage
public class AMQMessage
Combines the information that make up a deliverable message into a more manageable form.
Constructor Summary | |
---|---|
protected |
AMQMessage(AMQMessage msg)
|
|
AMQMessage(MessageStore messageStore,
org.apache.qpid.framing.BasicPublishBody publishBody)
|
|
AMQMessage(MessageStore messageStore,
org.apache.qpid.framing.BasicPublishBody publishBody,
boolean storeWhenComplete)
|
|
AMQMessage(MessageStore store,
org.apache.qpid.framing.BasicPublishBody publishBody,
org.apache.qpid.framing.ContentHeaderBody contentHeaderBody,
java.util.List<org.apache.qpid.framing.ContentBody> contentBodies)
|
|
AMQMessage(MessageStore store,
long messageId,
org.apache.qpid.framing.BasicPublishBody publishBody,
org.apache.qpid.framing.ContentHeaderBody contentHeaderBody,
java.util.List<org.apache.qpid.framing.ContentBody> contentBodies)
|
Method Summary | |
---|---|
void |
addContentBodyFrame(org.apache.qpid.framing.ContentBody contentBody)
|
void |
checkDeliveredToConsumer()
Called to enforce the 'immediate' flag. |
boolean |
checkToken(java.lang.Object token)
|
void |
decrementReference()
Threadsafe. |
void |
dequeue(AMQQueue queue)
|
void |
enqueue(AMQQueue queue)
|
java.util.List<org.apache.qpid.framing.ContentBody> |
getContentBodies()
|
org.apache.qpid.framing.ContentHeaderBody |
getContentHeaderBody()
|
org.apache.qpid.framing.CompositeAMQDataBlock |
getDataBlock(org.apache.mina.common.ByteBuffer encodedDeliverBody,
int channel)
|
org.apache.qpid.framing.CompositeAMQDataBlock |
getDataBlock(int channel,
java.lang.String consumerTag,
long deliveryTag)
|
long |
getMessageId()
|
java.util.List<org.apache.qpid.framing.AMQBody> |
getPayload()
|
org.apache.qpid.framing.BasicPublishBody |
getPublishBody()
|
AMQProtocolSession |
getPublisher()
|
TxnBuffer |
getTxnBuffer()
|
void |
incrementReference()
Threadsafe. |
boolean |
isAllContentReceived()
|
boolean |
isPersistent()
|
boolean |
isRedelivered()
|
void |
setContentBodies(java.util.List<org.apache.qpid.framing.ContentBody> contentBodies)
|
void |
setContentHeaderBody(org.apache.qpid.framing.ContentHeaderBody contentHeaderBody)
|
void |
setDeliveredToConsumer()
Called when this message is delivered to a consumer. |
void |
setPublisher(AMQProtocolSession publisher)
|
void |
setTxnBuffer(TxnBuffer buffer)
|
void |
storeMessage()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AMQMessage(MessageStore messageStore, org.apache.qpid.framing.BasicPublishBody publishBody)
public AMQMessage(MessageStore messageStore, org.apache.qpid.framing.BasicPublishBody publishBody, boolean storeWhenComplete)
public AMQMessage(MessageStore store, long messageId, org.apache.qpid.framing.BasicPublishBody publishBody, org.apache.qpid.framing.ContentHeaderBody contentHeaderBody, java.util.List<org.apache.qpid.framing.ContentBody> contentBodies) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public AMQMessage(MessageStore store, org.apache.qpid.framing.BasicPublishBody publishBody, org.apache.qpid.framing.ContentHeaderBody contentHeaderBody, java.util.List<org.apache.qpid.framing.ContentBody> contentBodies) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
protected AMQMessage(AMQMessage msg) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
Method Detail |
---|
public void storeMessage() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public org.apache.qpid.framing.CompositeAMQDataBlock getDataBlock(org.apache.mina.common.ByteBuffer encodedDeliverBody, int channel)
public org.apache.qpid.framing.CompositeAMQDataBlock getDataBlock(int channel, java.lang.String consumerTag, long deliveryTag)
public java.util.List<org.apache.qpid.framing.AMQBody> getPayload()
public org.apache.qpid.framing.BasicPublishBody getPublishBody()
public org.apache.qpid.framing.ContentHeaderBody getContentHeaderBody()
public void setContentHeaderBody(org.apache.qpid.framing.ContentHeaderBody contentHeaderBody) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public java.util.List<org.apache.qpid.framing.ContentBody> getContentBodies()
public void setContentBodies(java.util.List<org.apache.qpid.framing.ContentBody> contentBodies)
public void addContentBodyFrame(org.apache.qpid.framing.ContentBody contentBody) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public boolean isAllContentReceived()
public boolean isRedelivered()
public long getMessageId()
public void incrementReference()
public void decrementReference() throws MessageCleanupException
MessageCleanupException
public void setPublisher(AMQProtocolSession publisher)
public AMQProtocolSession getPublisher()
public boolean checkToken(java.lang.Object token)
public void enqueue(AMQQueue queue) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public void dequeue(AMQQueue queue) throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public boolean isPersistent() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public void setTxnBuffer(TxnBuffer buffer)
public TxnBuffer getTxnBuffer()
public void checkDeliveredToConsumer() throws NoConsumersException
NoConsumersException
- if the message is marked for
immediate delivery but has not been marked as delivered to a
consumerpublic void setDeliveredToConsumer()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |