Author: aconway
Date: Tue May 13 12:33:43 2008
New Revision: 655983
URL: http://svn.apache.org/viewvc?rev=655983&view=rev
Log:
Added sync() to ensure all acks are receivd before exiting the Dispatcher loop.
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/client/Dispatcher.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/Dispatcher.cpp
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/Dispatcher.cpp?rev=655983&r1=655982&r2=655983&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/Dispatcher.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/Dispatcher.cpp Tue May 13
12:33:43 2008
@@ -91,6 +91,7 @@
} catch (const ClosedException&) {
//ignore it and return
}
+ session.sync(); // Make sure all our acks are received before
returning.
}
void Dispatcher::stop()
