diff options
Diffstat (limited to 'qpid/python/qpid/spec010.py')
| -rw-r--r-- | qpid/python/qpid/spec010.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/qpid/python/qpid/spec010.py b/qpid/python/qpid/spec010.py index 4eb03008d0..03f60edc4e 100644 --- a/qpid/python/qpid/spec010.py +++ b/qpid/python/qpid/spec010.py @@ -192,6 +192,9 @@ class Composite(Type, Coded): def decode(self, codec): codec.read_size(self.size) + if self.code is not None: + code = codec.read_uint16() + assert self.code == code return datatypes.Struct(self, **self.decode_fields(codec)) def decode_fields(self, codec): @@ -211,6 +214,8 @@ class Composite(Type, Coded): def encode(self, codec, value): sc = StringCodec(self.spec) + if self.code is not None: + sc.write_uint16(self.code) self.encode_fields(sc, value) codec.write_size(self.size, len(sc.encoded)) codec.write(sc.encoded) |