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/Execution.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/Execution.h')
| -rw-r--r-- | cpp/src/qpid/client/Execution.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/Execution.h b/cpp/src/qpid/client/Execution.h index 557f7ece4a..5f717de586 100644 --- a/cpp/src/qpid/client/Execution.h +++ b/cpp/src/qpid/client/Execution.h @@ -41,6 +41,8 @@ public: virtual bool isComplete(const framing::SequenceNumber& id) = 0; virtual bool isCompleteUpTo(const framing::SequenceNumber& id) = 0; virtual void setCompletionListener(boost::function<void()>) = 0; + virtual void syncWait(const framing::SequenceNumber& id) = 0; + virtual framing::SequenceNumber lastSent() const = 0; }; }} |