diff options
Diffstat (limited to 'python/qpid/message.py')
| -rw-r--r-- | python/qpid/message.py | 8 |
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) |