diff options
Diffstat (limited to 'cpp/src/qpid/broker/Message.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/Message.cpp | 15 |
1 files changed, 13 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/Message.cpp b/cpp/src/qpid/broker/Message.cpp index 1b3f3bd827..c14f534826 100644 --- a/cpp/src/qpid/broker/Message.cpp +++ b/cpp/src/qpid/broker/Message.cpp @@ -42,12 +42,18 @@ using std::string; namespace qpid { namespace broker { -Message::Message() : deliveryCount(-1), publisher(0), expiration(FAR_FUTURE), timestamp(0), isManagementMessage(false) {} +Message::Message() : deliveryCount(-1), publisher(0), expiration(FAR_FUTURE), timestamp(0), + isManagementMessage(false), replicationId(0) +{} + Message::Message(boost::intrusive_ptr<Encoding> e, boost::intrusive_ptr<PersistableMessage> p) - : encoding(e), persistentContext(p), deliveryCount(-1), publisher(0), expiration(FAR_FUTURE), timestamp(0), isManagementMessage(false) + : encoding(e), persistentContext(p), deliveryCount(-1), publisher(0), + expiration(FAR_FUTURE), timestamp(0), isManagementMessage(false), + replicationId(0) { if (persistentContext) persistentContext->setIngressCompletion(e); } + Message::~Message() {} @@ -308,4 +314,9 @@ void Message::processProperties(MapHandler& handler) const encoding->processProperties(handler); } +uint64_t Message::getReplicationId() const { return replicationId; } + +void Message::setReplicationId(framing::SequenceNumber id) { replicationId = id; } + + }} // namespace qpid::broker |