diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-02-12 23:01:21 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-02-12 23:01:21 +0000 |
| commit | 68008d8656a1dc3e96bedc40a93c9c2389c10f2c (patch) | |
| tree | 274bdcdb223e0304217bb75b7d56c66a9ca7a99c /python/qmf2/tests/async_query.py | |
| parent | 68fb9a03641e50fbb6c045ac2f39091bf0bf9d08 (diff) | |
| download | qpid-python-68008d8656a1dc3e96bedc40a93c9c2389c10f2c.tar.gz | |
QPID-2261: add async method call workitems
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@909648 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qmf2/tests/async_query.py')
| -rw-r--r-- | python/qmf2/tests/async_query.py | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/python/qmf2/tests/async_query.py b/python/qmf2/tests/async_query.py index f598939d46..3a9a767bf0 100644 --- a/python/qmf2/tests/async_query.py +++ b/python/qmf2/tests/async_query.py @@ -227,7 +227,8 @@ class BaseTest(unittest.TestCase): # send queries query = QmfQuery.create_wildcard(QmfQuery.TARGET_SCHEMA_ID) - rc = self.console.do_async_query(agent, query, aname) + rc = self.console.do_query(agent, query, + _reply_handle=aname) self.assertTrue(rc) # done. Now wait for async responses @@ -273,7 +274,7 @@ class BaseTest(unittest.TestCase): # send queries query = QmfQuery.create_wildcard(QmfQuery.TARGET_OBJECT) - rc = self.console.do_async_query(agent, query, aname) + rc = self.console.do_query(agent, query, _reply_handle=aname) self.assertTrue(rc) # done. Now wait for async responses @@ -320,7 +321,7 @@ class BaseTest(unittest.TestCase): t_params = {QmfData.KEY_SCHEMA_ID: SchemaClassId("MyPackage", "MyClass")} query = QmfQuery.create_wildcard(QmfQuery.TARGET_OBJECT, t_params) # - rc = self.console.do_async_query(agent, query, aname) + rc = self.console.do_query(agent, query, _reply_handle=aname) self.assertTrue(rc) # done. Now wait for async responses @@ -371,7 +372,7 @@ class BaseTest(unittest.TestCase): # send queries query = QmfQuery.create_wildcard(QmfQuery.TARGET_SCHEMA) - rc = self.console.do_async_query(agent, query, aname) + rc = self.console.do_query(agent, query, _reply_handle=aname) self.assertTrue(rc) # done. Now wait for async responses @@ -436,8 +437,9 @@ class BaseTest(unittest.TestCase): # now send queries to agents that no longer exist for agent in agents: query = QmfQuery.create_wildcard(QmfQuery.TARGET_SCHEMA) - rc = self.console.do_async_query(agent, query, agent.get_name(), - _timeout=2) + rc = self.console.do_query(agent, query, + _reply_handle=agent.get_name(), + _timeout=2) self.assertTrue(rc) # done. Now wait for async responses due to timeouts |