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 | 761a0149a3e72ceec7fc2f30f90dba21756da2ae (patch) | |
| tree | 2bfb186e562cd79ba379a8991d37a6a5be552848 /cpp | |
| parent | 6c158467aac165a698b56a2cb51ac6aeb5f7c20c (diff) | |
| download | qpid-python-761a0149a3e72ceec7fc2f30f90dba21756da2ae.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/qpid@1070481 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp')
| -rw-r--r-- | cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp index 42eceaf9f6..030b804143 100644 --- a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp +++ b/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); |