From 862b354f6f777314cd4013f5cbd5aaf0003808d7 Mon Sep 17 00:00:00 2001
From: Alan Conway <aconway@apache.org>
Date: Wed, 21 Mar 2007 02:03:49 +0000
Subject: * python/qpid/*.py:: apply 0-9 changes missed by merge. *
 python/cpp_failing_0-9.txt: update tests to refer to tess_0-9

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@520704 13f79535-47bb-0310-9956-ffa450edef68
---
 python/qpid/client.py  |  3 +++
 python/qpid/message.py |  9 ++++++---
 python/qpid/peer.py    | 15 ++++++++++-----
 3 files changed, 19 insertions(+), 8 deletions(-)

(limited to 'python/qpid')

diff --git a/python/qpid/client.py b/python/qpid/client.py
index e548ef0e99..cdceb87bdf 100644
--- a/python/qpid/client.py
+++ b/python/qpid/client.py
@@ -131,6 +131,9 @@ class ClientDelegate(Delegate):
   def basic_deliver(self, ch, msg):
     self.client.queue(msg.consumer_tag).put(msg)
 
+  def channel_pong(self, ch, msg):
+    msg.ok()
+
   def channel_close(self, ch, msg):
     ch.close(msg)
 
diff --git a/python/qpid/message.py b/python/qpid/message.py
index 29c8654937..f80293180e 100644
--- a/python/qpid/message.py
+++ b/python/qpid/message.py
@@ -47,9 +47,12 @@ class Message:
     else:
       for r in self.method.responses:
         if attr == r.name:
-          result = lambda *args, **kwargs: \
-                   self.channel.respond(Method(r, r.arguments(*args, **kwargs)),
-                                        self.frame)
+          def respond(*args, **kwargs):
+            batch=0
+            if kwargs.has_key("batchoffset"):
+              batch=kwargs.pop("batchoffset")
+            self.channel.respond(Method(r, r.arguments(*args, **kwargs)), batch, self.frame)
+          result = respond
           break
       else:
         raise AttributeError(attr)
diff --git a/python/qpid/peer.py b/python/qpid/peer.py
index 28db20f187..72e6a19bc7 100644
--- a/python/qpid/peer.py
+++ b/python/qpid/peer.py
@@ -129,6 +129,8 @@ class Peer:
           content = None
 
         self.delegate(channel, Message(channel, frame, content))
+    except QueueClosed, e:
+      self.close(e)
     except:
       self.fatal()
 
@@ -156,12 +158,15 @@ class Responder:
     self.write = writer
     self.sequence = Sequence(1)
 
-  def respond(self, method, request):
+  def respond(self, method, batch, request):
     if isinstance(request, Method):
       self.write(method)
     else:
-      # XXX: batching
-      frame = Response(self.sequence.next(), request.id, 0, method)
+      # allow batching from frame at either end
+      if batch<0:
+        frame = Response(self.sequence.next(), request.id+batch, -batch, method)
+      else:
+        frame = Response(self.sequence.next(), request.id, batch, method)
       self.write(frame)
 
 class Closed(Exception): pass
@@ -238,8 +243,8 @@ class Channel:
   def request(self, method, listener, content = None):
     self.requester.request(method, listener, content)
 
-  def respond(self, method, request):
-    self.responder.respond(method, request)
+  def respond(self, method, batch, request):
+    self.responder.respond(method, batch, request)
 
   def invoke(self, type, args, kwargs):
     content = kwargs.pop("content", None)
-- 
cgit v1.2.1