org.apache.qpid.server.message
Class MessageMetaData
java.lang.Object
org.apache.qpid.server.message.MessageMetaData
- All Implemented Interfaces:
- StorableMessageMetaData
public class MessageMetaData
- extends Object
- implements StorableMessageMetaData
Encapsulates a publish body and a content header. In the context of the message store these are treated as a
single unit.
Constructor Summary |
MessageMetaData(org.apache.qpid.framing.abstraction.MessagePublishInfo publishBody,
org.apache.qpid.framing.ContentHeaderBody contentHeaderBody,
int contentChunkCount)
|
MessageMetaData(org.apache.qpid.framing.abstraction.MessagePublishInfo publishBody,
org.apache.qpid.framing.ContentHeaderBody contentHeaderBody,
int contentChunkCount,
long arrivalTime)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FACTORY
public static final MessageMetaDataType.Factory<MessageMetaData> FACTORY
MessageMetaData
public MessageMetaData(org.apache.qpid.framing.abstraction.MessagePublishInfo publishBody,
org.apache.qpid.framing.ContentHeaderBody contentHeaderBody,
int contentChunkCount)
MessageMetaData
public MessageMetaData(org.apache.qpid.framing.abstraction.MessagePublishInfo publishBody,
org.apache.qpid.framing.ContentHeaderBody contentHeaderBody,
int contentChunkCount,
long arrivalTime)
getContentChunkCount
public int getContentChunkCount()
setContentChunkCount
public void setContentChunkCount(int contentChunkCount)
getContentHeaderBody
public org.apache.qpid.framing.ContentHeaderBody getContentHeaderBody()
setContentHeaderBody
public void setContentHeaderBody(org.apache.qpid.framing.ContentHeaderBody contentHeaderBody)
getMessagePublishInfo
public org.apache.qpid.framing.abstraction.MessagePublishInfo getMessagePublishInfo()
setMessagePublishInfo
public void setMessagePublishInfo(org.apache.qpid.framing.abstraction.MessagePublishInfo messagePublishInfo)
getArrivalTime
public long getArrivalTime()
setArrivalTime
public void setArrivalTime(long arrivalTime)
getType
public MessageMetaDataType getType()
- Specified by:
getType
in interface StorableMessageMetaData
getStorableSize
public int getStorableSize()
- Specified by:
getStorableSize
in interface StorableMessageMetaData
writeToBuffer
public int writeToBuffer(int offset,
ByteBuffer dest)
- Specified by:
writeToBuffer
in interface StorableMessageMetaData
getContentSize
public int getContentSize()
- Specified by:
getContentSize
in interface StorableMessageMetaData
isPersistent
public boolean isPersistent()
- Specified by:
isPersistent
in interface StorableMessageMetaData
getMessageHeader
public AMQMessageHeader getMessageHeader()
Licensed to the Apache Software Foundation