From 86779be122dea590bc1e5201c58777ea3e362a95 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Wed, 5 Mar 2008 14:39:40 +0000 Subject: added incoming queues for messages; altered session dispatch to send entire assembly to a single handler; added logging switch for hello-010-world git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@633861 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/assembler.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'python/qpid/assembler.py') diff --git a/python/qpid/assembler.py b/python/qpid/assembler.py index aac8b80cb4..fe78baaceb 100644 --- a/python/qpid/assembler.py +++ b/python/qpid/assembler.py @@ -46,7 +46,9 @@ class Segment: def decode_command(self, spec): sc = StringCodec(spec, self.payload) - return sc.read_command() + cmd = sc.read_command() + cmd.id = self.id + return cmd def decode_header(self, spec): sc = StringCodec(spec, self.payload) @@ -56,7 +58,7 @@ class Segment: return values def decode_body(self, spec): - return self + return self.payload def __str__(self): return "%s%s %s %s %s %r" % (int(self.first), int(self.last), self.type, -- cgit v1.2.1