From 80406d0fb680239a0141b81fb0b9f20d20c9b1e1 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 27 Jul 2007 15:44:52 +0000 Subject: 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 --- python/qpid/message.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'python/qpid/message.py') 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) -- cgit v1.2.1