diff options
| author | Gordon Sim <gsim@apache.org> | 2008-04-23 14:07:07 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-04-23 14:07:07 +0000 |
| commit | c25d4ec64b056134bb730932b30f382ca3caa008 (patch) | |
| tree | b8d8e8113c15dbc567997480f68b5182b1e5973d | |
| parent | b4ab7778b1f18d836876132700d35222b9f7d55a (diff) | |
| download | qpid-python-c25d4ec64b056134bb730932b30f382ca3caa008.tar.gz | |
Add support for reading 0-10 arrays; Set sync bit on session header for commands sent with auto_sync on.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@650875 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | python/qpid/codec010.py | 9 | ||||
| -rw-r--r-- | python/qpid/session.py | 1 |
2 files changed, 9 insertions, 1 deletions
diff --git a/python/qpid/codec010.py b/python/qpid/codec010.py index 27fcd5d418..0ba3341665 100644 --- a/python/qpid/codec010.py +++ b/python/qpid/codec010.py @@ -179,7 +179,14 @@ class Codec(Packer): def write_array(self, a): pass def read_array(self): - pass + sc = StringCodec(self.spec, self.read_vbin32()) + type = self.spec.types[sc.read_uint8()] + count = sc.read_uint32() + result = [] + while count: + result.append(type.decode(sc)) + count = count - 1 + return result def read_struct32(self): size = self.read_uint32() diff --git a/python/qpid/session.py b/python/qpid/session.py index f649b95a2c..11249ca435 100644 --- a/python/qpid/session.py +++ b/python/qpid/session.py @@ -152,6 +152,7 @@ class Session(Invoker): cmd = type.new(args, kwargs) sc = StringCodec(self.spec) hdr = Struct(self.spec["session.header"]) + hdr.sync = self.auto_sync sc.write_command(hdr, cmd) seg = Segment(True, (message == None or |