summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/Execution.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-04-20 12:10:37 +0000
committerGordon Sim <gsim@apache.org>2008-04-20 12:10:37 +0000
commit0637677cf6653256b67c82dcb74f35133601220c (patch)
tree8507bb8373e8b6dfd8c9b96fcb4b262fd4d61501 /cpp/src/qpid/client/Execution.h
parent48dab065ef526f68a5a7d4c4ba22c5b8b2e2e026 (diff)
downloadqpid-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.h24
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);
};
}}