#include <BrokerMessage.h>
Inheritance diagram for qpid::broker::BasicMessage:
Public Types | |
typedef boost::shared_ptr< BasicMessage > | shared_ptr |
Public Member Functions | |
BasicMessage (const ConnectionToken *const publisher, const string &exchange, const string &routingKey, bool mandatory, bool immediate, boost::shared_ptr< framing::AMQMethodBody > respondTo) | |
void | setHeader (boost::shared_ptr< framing::AMQHeaderBody > header) |
void | addContent (framing::AMQContentBody::shared_ptr data) |
bool | isComplete () |
void | deliver (framing::ChannelAdapter &, const string &consumerTag, uint64_t deliveryTag, uint32_t framesize) |
void | sendGetOk (const framing::MethodContext &, const std::string &destination, uint32_t messageCount, uint64_t deliveryTag, uint32_t framesize) |
Used to return a message in response to a get from a queue. | |
framing::BasicHeaderProperties * | getHeaderProperties () |
const framing::FieldTable & | getApplicationHeaders () |
bool | isPersistent () |
uint64_t | contentSize () const |
void | decode (framing::Buffer &buffer, bool headersOnly=false, uint32_t contentChunkSize=0) |
void | decodeHeader (framing::Buffer &buffer) |
void | decodeContent (framing::Buffer &buffer, uint32_t contentChunkSize=0) |
void | encode (framing::Buffer &buffer) const |
Encodes the persistable state of this object into the supplied buffer. | |
void | encodeHeader (framing::Buffer &buffer) const |
void | encodeContent (framing::Buffer &buffer) const |
uint32_t | encodedSize () const |
uint32_t | encodedHeaderSize () const |
uint32_t | encodedContentSize () const |
void | releaseContent (MessageStore *store) |
Releases the in-memory content data held by this message. | |
uint64_t | expectedContentSize () |
If headers have been received, returns the expected content size else returns 0. | |
void | setContent (std::auto_ptr< Content > &content) |
Sets the 'content' implementation of this message (the message controls the lifecycle of the content instance it uses). |
a header body, a list of content bodies and some details about the publication request.
uint32_t qpid::broker::BasicMessage::encodedContentSize | ( | ) | const [virtual] |
Implements qpid::broker::Message.
uint32_t qpid::broker::BasicMessage::encodedHeaderSize | ( | ) | const [virtual] |
Implements qpid::broker::Message.
uint32_t qpid::broker::BasicMessage::encodedSize | ( | ) | const [virtual] |
Implements qpid::broker::Message.
void qpid::broker::BasicMessage::releaseContent | ( | MessageStore * | store | ) | [virtual] |
Releases the in-memory content data held by this message.
Must pass in a store from which the data can be reloaded.
Reimplemented from qpid::broker::Message.