Use execution layer to acknowledge messages.

Turn off 0-9 framing of requests and responses. 
Some refactoring around message delivery.



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@560285 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 1 deletions

diff --git a/python/qpid/message.py b/python/qpid/message.py
index f80293180e..970ab9d974 100644
--- a/python/qpid/message.py
+++ b/python/qpid/message.py
@@ -26,7 +26,10 @@ class Message:
     self.frame = frame
     self.method = frame.method_type
     self.content = content
-
+    if self.method.klass.name != "execution":
+      self.command_id = self.channel.incoming_completion.sequence.next()
+      #print "allocated: ", self.command_id, "to ", self.method.klass.name, "_", self.method.name
+      
   def __len__(self):
     return len(self.frame.args)
 
@@ -66,3 +69,6 @@ class Message:
 
   def __repr__(self):
     return Message.REPR % (self.method, self.frame.args, self.content)
+
+  def complete(self, cumulative=True):
+    self.channel.incoming_completion.complete(mark=self.command_id, cumulative=cumulative)