From 36cfeb13b8ad4b532f7f9c2b48ac2353e6217bcd Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 31 Mar 2008 12:51:36 +0000 Subject: Re-introduced old 'no-local' behaviour for exclusive queues via a proprietary arg to queue.declare. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@642981 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/testlib.py | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'python/qpid') diff --git a/python/qpid/testlib.py b/python/qpid/testlib.py index f633c4e77d..b6cf6d7446 100644 --- a/python/qpid/testlib.py +++ b/python/qpid/testlib.py @@ -361,3 +361,10 @@ class TestBase010(unittest.TestCase): def tearDown(self): if not self.session.error(): self.session.close(timeout=10) self.conn.close(timeout=10) + + def subscribe(self, session=None, **keys): + session = session or self.session + consumer_tag = keys["destination"] + session.message_subscribe(**keys) + session.message_flow(destination=consumer_tag, unit=0, value=0xFFFFFFFF) + session.message_flow(destination=consumer_tag, unit=1, value=0xFFFFFFFF) -- cgit v1.2.1