diff options
| author | Gordon Sim <gsim@apache.org> | 2008-03-31 12:51:36 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-03-31 12:51:36 +0000 |
| commit | 36cfeb13b8ad4b532f7f9c2b48ac2353e6217bcd (patch) | |
| tree | 3131f539a580a7ef905623787d86ba2cdb515f62 /python/qpid/testlib.py | |
| parent | 4c0600f324a10a59cf505b991e687d9888fa3a16 (diff) | |
| download | qpid-python-36cfeb13b8ad4b532f7f9c2b48ac2353e6217bcd.tar.gz | |
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
Diffstat (limited to 'python/qpid/testlib.py')
| -rw-r--r-- | python/qpid/testlib.py | 7 |
1 files changed, 7 insertions, 0 deletions
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) |