diff options
Diffstat (limited to 'cpp/src/qpid/broker/Message.cpp')
-rw-r--r-- | cpp/src/qpid/broker/Message.cpp | 16 |
1 files changed, 0 insertions, 16 deletions
diff --git a/cpp/src/qpid/broker/Message.cpp b/cpp/src/qpid/broker/Message.cpp index 147b9e7a6a..c589669e5a 100644 --- a/cpp/src/qpid/broker/Message.cpp +++ b/cpp/src/qpid/broker/Message.cpp @@ -399,22 +399,6 @@ bool Message::hasExpired() return expiryPolicy && expiryPolicy->hasExpired(*this); } -boost::intrusive_ptr<Message>& Message::getReplacementMessage(const Queue* qfor) const -{ - sys::Mutex::ScopedLock l(lock); - 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) -{ - sys::Mutex::ScopedLock l(lock); - replacement[qfor] = msg; -} - namespace { struct ScopedSet { sys::Monitor& lock; |