org.apache.qpid.server.message
Class MessageMetaData

java.lang.Object
  extended by 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.


Field Summary
static MessageMetaDataType.Factory<MessageMetaData> FACTORY
           
 
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)
           
 
Method Summary
 long getArrivalTime()
           
 int getContentChunkCount()
           
 org.apache.qpid.framing.ContentHeaderBody getContentHeaderBody()
           
 int getContentSize()
           
 AMQMessageHeader getMessageHeader()
           
 org.apache.qpid.framing.abstraction.MessagePublishInfo getMessagePublishInfo()
           
 int getStorableSize()
           
 MessageMetaDataType getType()
           
 boolean isPersistent()
           
 void setArrivalTime(long arrivalTime)
           
 void setContentChunkCount(int contentChunkCount)
           
 void setContentHeaderBody(org.apache.qpid.framing.ContentHeaderBody contentHeaderBody)
           
 void setMessagePublishInfo(org.apache.qpid.framing.abstraction.MessagePublishInfo messagePublishInfo)
           
 int writeToBuffer(int offset, ByteBuffer dest)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

FACTORY

public static final MessageMetaDataType.Factory<MessageMetaData> FACTORY
Constructor Detail

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)
Method Detail

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