diff options
author | Gordon Sim <gsim@apache.org> | 2008-04-20 12:10:37 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2008-04-20 12:10:37 +0000 |
commit | 0637677cf6653256b67c82dcb74f35133601220c (patch) | |
tree | 8507bb8373e8b6dfd8c9b96fcb4b262fd4d61501 /cpp/src/qpid/client/Execution.h | |
parent | 48dab065ef526f68a5a7d4c4ba22c5b8b2e2e026 (diff) | |
download | qpid-python-0637677cf6653256b67c82dcb74f35133601220c.tar.gz |
QPID-920: converted c++ client to use final 0-10 protocol
* connection handler converted to using invoker & proxy and updated to final method defs
* SessionCore & ExecutionHandler replace by SessionImpl
* simplified handling of completion & results, removed handling of responses
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@649915 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/Execution.h')
-rw-r--r-- | cpp/src/qpid/client/Execution.h | 24 |
1 files changed, 15 insertions, 9 deletions
diff --git a/cpp/src/qpid/client/Execution.h b/cpp/src/qpid/client/Execution.h index 5f717de586..e4b2db23e1 100644 --- a/cpp/src/qpid/client/Execution.h +++ b/cpp/src/qpid/client/Execution.h @@ -28,21 +28,27 @@ namespace qpid { namespace client { /** - * Provides more detailed access to the amqp 'execution layer'. + * Provides access to more detailed aspects of the session + * implementation. */ class Execution { public: virtual ~Execution() {} - virtual void sendSyncRequest() = 0; - virtual void sendFlushRequest() = 0; - virtual void completed(const framing::SequenceNumber& id, bool cumulative, bool send) = 0; + /** + * Mark the incoming command with the specified id as completed + */ + virtual void markCompleted(const framing::SequenceNumber& id, bool cumulative, bool notifyPeer) = 0; + /** + * Provides access to the demultiplexing function within the + * session implementation + */ virtual Demux& getDemux() = 0; - 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; + /** + * Wait until notification has been received of completion of the + * outgoing command with the specified id. + */ + void waitForCompletion(const framing::SequenceNumber& id); }; }} |