You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gm...@apache.org on 2018/03/21 14:41:42 UTC
qpid-dispatch git commit: DISPATCH-947 - Initial fix to remove
Messenger from base system test class. This will make all but 4 system tests
fail.
Repository: qpid-dispatch
Updated Branches:
refs/heads/master f80c40ff4 -> 143246f4e
DISPATCH-947 - Initial fix to remove Messenger from base system test class. This will make all but 4 system tests fail.
Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/143246f4
Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/143246f4
Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/143246f4
Branch: refs/heads/master
Commit: 143246f4e873f4adb22a4415b7b4680398652b36
Parents: f80c40f
Author: Ganesh Murthy <gm...@redhat.com>
Authored: Wed Mar 21 10:41:22 2018 -0400
Committer: Ganesh Murthy <gm...@redhat.com>
Committed: Wed Mar 21 10:41:22 2018 -0400
----------------------------------------------------------------------
tests/system_test.py | 27 ---------------------------
1 file changed, 27 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/143246f4/tests/system_test.py
----------------------------------------------------------------------
diff --git a/tests/system_test.py b/tests/system_test.py
index 71abbc7..a6937ce 100755
--- a/tests/system_test.py
+++ b/tests/system_test.py
@@ -475,33 +475,6 @@ class Qdrouterd(Process):
def wait_router_connected(self, router_id, **retry_kwargs):
retry(lambda: self.is_router_connected(router_id), **retry_kwargs)
-class Messenger(proton.Messenger):
- """Convenience additions to proton.Messenger"""
-
- def __init__(self, name=None, timeout=TIMEOUT, blocking=True):
- super(Messenger, self).__init__(name)
- self.timeout = timeout
- self.blocking = blocking
-
- def flush(self):
- """Call work() till there is no work left."""
- while self.work(0.1):
- pass
-
- def fetch(self, accept=True):
- """Fetch a single message"""
- msg = Message()
- self.recv(1)
- self.get(msg)
- if accept:
- self.accept()
- return msg
-
- def subscribe(self, source, **retry_args):
- """Do a proton.Messenger.subscribe and wait till the address is available."""
- subscription = super(Messenger, self).subscribe(source)
- assert retry(lambda: subscription.address, **retry_args) # Wait for address
- return subscription
class Tester(object):
"""Tools for use by TestCase
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org