From 283b61527c3c0958d5a5af757077dae219f5d5fa Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Thu, 23 Oct 2008 18:57:38 +0000
Subject: Some fixes to the LVQ (primarily a patch from cctrieloff@redhat.com)

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@707446 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/broker/Message.cpp | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

(limited to 'cpp/src/qpid/broker/Message.cpp')

diff --git a/cpp/src/qpid/broker/Message.cpp b/cpp/src/qpid/broker/Message.cpp
index 0302bc1dbd..4a63962ecf 100644
--- a/cpp/src/qpid/broker/Message.cpp
+++ b/cpp/src/qpid/broker/Message.cpp
@@ -324,3 +324,17 @@ bool Message::hasExpired() const
 {
     return expiration < FAR_FUTURE && expiration < AbsTime::now();
 }
+
+boost::intrusive_ptr<Message>& Message::getReplacementMessage(const Queue* qfor) const
+{
+    Replacement::iterator i = replacement.find(qfor);
+    if (i != replacement.end()){
+        return i->second;
+    }		 
+    return empty;
+}
+
+void Message::setReplacementMessage(boost::intrusive_ptr<Message> msg, const Queue* qfor)
+{
+    replacement[qfor] = msg;
+}
-- 
cgit v1.2.1