summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/ExecutionHandler.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-08-21 15:51:41 +0000
committerGordon Sim <gsim@apache.org>2007-08-21 15:51:41 +0000
commitbb2883b9f5cfad0e028a9849ed91e36418a2d0ff (patch)
tree555686e2e819a875048610d88c2cee8e336b3687 /cpp/src/qpid/client/ExecutionHandler.cpp
parent955d5ccb544ff4f56d35c40aa8934cbf4dfff14e (diff)
downloadqpid-python-bb2883b9f5cfad0e028a9849ed91e36418a2d0ff.tar.gz
Refresh of transitional xml to more closely reflect latest specification
Initial execution-result support (not yet handled on c++ client) Generation is now all done through the ruby code (it is a little slower at present I'm afraid, will try to speed it up over the next weeks) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@568174 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/ExecutionHandler.cpp')
-rw-r--r--cpp/src/qpid/client/ExecutionHandler.cpp22
1 files changed, 21 insertions, 1 deletions
diff --git a/cpp/src/qpid/client/ExecutionHandler.cpp b/cpp/src/qpid/client/ExecutionHandler.cpp
index 6ee6429b6b..6c2600d00b 100644
--- a/cpp/src/qpid/client/ExecutionHandler.cpp
+++ b/cpp/src/qpid/client/ExecutionHandler.cpp
@@ -78,7 +78,7 @@ void ExecutionHandler::handle(AMQFrame& frame)
}
}
-void ExecutionHandler::complete(uint32_t cumulative, SequenceNumberSet range)
+void ExecutionHandler::complete(uint32_t cumulative, const SequenceNumberSet& range)
{
SequenceNumber mark(cumulative);
if (outgoing.lwm < mark) {
@@ -101,6 +101,26 @@ void ExecutionHandler::flush()
incoming.lwm = incoming.hwm;
}
+void ExecutionHandler::noop()
+{
+ //do nothing
+}
+
+void ExecutionHandler::result(uint32_t /*command*/, const std::string& /*data*/)
+{
+ //TODO: need to signal the result to the appropriate listener
+}
+
+void ExecutionHandler::sync()
+{
+ //TODO: implement (the application is in charge of completion of
+ //some commands, so need to track completion for them).
+
+ //This shouldn't ever need to be called by the server (in my
+ //opinion) as the server never needs to synchronise with the
+ //clients execution
+}
+
void ExecutionHandler::sendFlush()
{
AMQFrame frame(version, 0, ExecutionFlushBody());