diff options
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) |