summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Message.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/Message.cpp')
-rw-r--r--cpp/src/qpid/broker/Message.cpp15
1 files changed, 15 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Message.cpp b/cpp/src/qpid/broker/Message.cpp
index 2c3c444baa..b912cd3a1c 100644
--- a/cpp/src/qpid/broker/Message.cpp
+++ b/cpp/src/qpid/broker/Message.cpp
@@ -401,4 +401,19 @@ framing::FieldTable& Message::getOrInsertHeaders()
return getProperties<MessageProperties>()->getApplicationHeaders();
}
+
+void Message::setUpdateDestination(const std::string& d)
+{
+ updateDestination = d;
+}
+
+
+bool Message::isUpdateMessage()
+{
+ return updateDestination.size() && isA<MessageTransferBody>()
+ && getMethod<MessageTransferBody>()->getDestination() == updateDestination;
+}
+
+std::string Message::updateDestination;
+
}} // namespace qpid::broker