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 | 05cf26aace94fa45d419a7c8b45f131b866ef89b (patch) | |
| tree | 2bfb186e562cd79ba379a8991d37a6a5be552848 | |
| parent | 15825f7a785de397c24873ef6c0e3f720d3268e8 (diff) | |
| download | qpid-python-05cf26aace94fa45d419a7c8b45f131b866ef89b.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
| -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); |