diff options
Diffstat (limited to 'cpp/src/qpid/broker/IncompleteMessageList.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/IncompleteMessageList.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/IncompleteMessageList.cpp b/cpp/src/qpid/broker/IncompleteMessageList.cpp index 26c7a83d2f..2077e633ec 100644 --- a/cpp/src/qpid/broker/IncompleteMessageList.cpp +++ b/cpp/src/qpid/broker/IncompleteMessageList.cpp @@ -58,7 +58,7 @@ void IncompleteMessageList::process(const CompletionListener& listen, bool sync) msg->flush(); // Can re-enter IncompleteMessageList::enqueueComplete } while (!msg->isEnqueueComplete()) - lock.wait(); + lock.wait(); } else { //leave the message as incomplete for now return; |
