From c612a6c6200fd9a8f9830cbad062b30b465d3dfe Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Mon, 18 Feb 2008 21:54:02 +0000 Subject: Fixed race condition in the examples: when a listener program prints its "ready" message, the commands it has sent to the broker may not yet be complete. This results in sporadic lost messages if the producer is started immediately (e.g. by a script.) - Added Session::sync(), wait till all commands to date have completed. - Call sync() before printing "ready" in listener example programs - Removed sleep from verify script git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@628875 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/client/SessionBase.h | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'cpp/src/qpid/client/SessionBase.h') diff --git a/cpp/src/qpid/client/SessionBase.h b/cpp/src/qpid/client/SessionBase.h index 890dbd269b..87c0892b61 100644 --- a/cpp/src/qpid/client/SessionBase.h +++ b/cpp/src/qpid/client/SessionBase.h @@ -84,6 +84,11 @@ class SessionBase /** Close the session */ void close(); + + /** Synchronize with the broker. Wait for all commands issued so far in + * the session to complete. + */ + void sync(); Execution& getExecution(); -- cgit v1.2.1