summaryrefslogtreecommitdiff
path: root/qpid/python/qpid/codec.py
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-07-27 15:44:52 +0000
committerGordon Sim <gsim@apache.org>2007-07-27 15:44:52 +0000
commita2f1ddbe4175c6136b1188faeccaf1f8e561e3b2 (patch)
treefec659c6eb749cf6eca5b790a439962dd930281d /qpid/python/qpid/codec.py
parent6054ada715929a82afa55601f1c4b5f226cf45b8 (diff)
downloadqpid-python-a2f1ddbe4175c6136b1188faeccaf1f8e561e3b2.tar.gz
Use execution layer to acknowledge messages.
Turn off 0-9 framing of requests and responses. Some refactoring around message delivery. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@560285 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python/qpid/codec.py')
-rw-r--r--qpid/python/qpid/codec.py25
1 files changed, 15 insertions, 10 deletions
diff --git a/qpid/python/qpid/codec.py b/qpid/python/qpid/codec.py
index a5228e8003..a0d9696c8b 100644
--- a/qpid/python/qpid/codec.py
+++ b/qpid/python/qpid/codec.py
@@ -329,12 +329,6 @@ class Codec:
return ReferenceId(self.decode_longstr())
# new domains for 0-10:
-
- def encode_uuid(self, s):
- self.encode_longstr(s)
-
- def decode_uuid(self):
- return self.decode_longstr()
def encode_rfc1982_long(self, s):
self.encode_long(s)
@@ -342,10 +336,21 @@ class Codec:
def decode_rfc1982_long(self):
return self.decode_long()
- #Not done yet
def encode_rfc1982_long_set(self, s):
- self.encode_short(0)
+ self.encode_short(len(s))
+ for i in s:
+ self.encode_long(i)
def decode_rfc1982_long_set(self):
- self.decode_short()
- return 0;
+ count = self.decode_short()
+ set = []
+ for i in range(0, count):
+ set.append(self.decode_long())
+ return set;
+
+ #not correct for 0-10 yet
+ def encode_uuid(self, s):
+ self.encode_longstr(s)
+
+ def decode_uuid(self):
+ return self.decode_longstr()