diff options
Diffstat (limited to 'cpp/src/qpid/broker/Message.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/Message.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Message.cpp b/cpp/src/qpid/broker/Message.cpp index ce0477b08c..133e2b5ad1 100644 --- a/cpp/src/qpid/broker/Message.cpp +++ b/cpp/src/qpid/broker/Message.cpp @@ -344,6 +344,7 @@ bool Message::hasExpired() 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; @@ -353,6 +354,7 @@ boost::intrusive_ptr<Message>& Message::getReplacementMessage(const Queue* qfor) void Message::setReplacementMessage(boost::intrusive_ptr<Message> msg, const Queue* qfor) { + sys::Mutex::ScopedLock l(lock); replacement[qfor] = msg; } |