diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-03-05 14:39:40 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-03-05 14:39:40 +0000 |
| commit | 86779be122dea590bc1e5201c58777ea3e362a95 (patch) | |
| tree | 5867b18efe04c62c99e1ca14d177b0eda894bd82 /python/qpid/assembler.py | |
| parent | 00f2ca6cf33f77e44b94db2701830f8c9bcd794e (diff) | |
| download | qpid-python-86779be122dea590bc1e5201c58777ea3e362a95.tar.gz | |
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
Diffstat (limited to 'python/qpid/assembler.py')
| -rw-r--r-- | python/qpid/assembler.py | 6 |
1 files changed, 4 insertions, 2 deletions
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, |