diff options
| author | Gordon Sim <gsim@apache.org> | 2011-02-14 13:09:17 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2011-02-14 13:09:17 +0000 |
| commit | d92d05635b2f602911c07a82a13c7dfa6e4a116d (patch) | |
| tree | 1c3f1ccd3da978e31ca937238dcf0bb559c8e3c6 /qpid/cpp/src | |
| parent | 501b280c516e6d3e37d7cf83505d2878955c7d0c (diff) | |
| download | qpid-python-d92d05635b2f602911c07a82a13c7dfa6e4a116d.tar.gz | |
QPID-3040: Prevent race between receipt and release of messages causing intermittent test failures.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1070481 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp b/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp index 42eceaf9f6..030b804143 100644 --- a/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp +++ b/qpid/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp @@ -193,7 +193,7 @@ void ReceiverImpl::closeImpl() sys::Mutex::ScopedLock l(lock); if (state != CANCELLED) { state = CANCELLED; - session.messageStop(destination); + sync(session).messageStop(destination); parent->releasePending(destination); source->cancel(session, destination); parent->receiverCancelled(destination); |