diff options
| author | Alan Conway <aconway@apache.org> | 2008-02-18 21:54:02 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-02-18 21:54:02 +0000 |
| commit | c612a6c6200fd9a8f9830cbad062b30b465d3dfe (patch) | |
| tree | fd427336d51e5c091529eb53743592294f7748be /cpp/src/qpid/client/SessionBase.h | |
| parent | 3966d8be198296525a87a6bd88a42c4bb4f20d03 (diff) | |
| download | qpid-python-c612a6c6200fd9a8f9830cbad062b30b465d3dfe.tar.gz | |
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
Diffstat (limited to 'cpp/src/qpid/client/SessionBase.h')
| -rw-r--r-- | cpp/src/qpid/client/SessionBase.h | 5 |
1 files changed, 5 insertions, 0 deletions
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(); |