diff options
| author | Alan Conway <aconway@apache.org> | 2009-10-09 19:37:14 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2009-10-09 19:37:14 +0000 |
| commit | c68d17bf36649f3ba68334c3147e2d0da7246e67 (patch) | |
| tree | ac0b2cb867301de664d204d6330a6b5fd36e7903 /cpp/src/qpid/broker/Message.h | |
| parent | addd79a8d7e007d79f6164e70e1a97f78c69b9a8 (diff) | |
| download | qpid-python-c68d17bf36649f3ba68334c3147e2d0da7246e67.tar.gz | |
Fix race condition in enqueue/dequeue callbacks.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@823669 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Message.h')
| -rw-r--r-- | cpp/src/qpid/broker/Message.h | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Message.h b/cpp/src/qpid/broker/Message.h index 87ff78b3b0..3894960c95 100644 --- a/cpp/src/qpid/broker/Message.h +++ b/cpp/src/qpid/broker/Message.h @@ -184,8 +184,11 @@ public: mutable Replacement replacement; mutable boost::intrusive_ptr<Message> empty; + + sys::Mutex callbackLock; MessageCallback* enqueueCallback; MessageCallback* dequeueCallback; + uint32_t requiredCredit; static std::string updateDestination; }; |