Repository: qpid-dispatch Updated Branches: refs/heads/master 2b1d8f67f -> e605fbd09
DISPATCH-179 - Fixed system_tests_protocol_family, replaced discard test with test_simple_pre_settled Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/e605fbd0 Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/e605fbd0 Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/e605fbd0 Branch: refs/heads/master Commit: e605fbd098abf613f2780c95d68914e6dcea47bb Parents: 2b1d8f6 Author: Ganesh Murthy <[email protected]> Authored: Wed Mar 23 09:07:02 2016 -0400 Committer: Ganesh Murthy <[email protected]> Committed: Wed Mar 23 09:07:02 2016 -0400 ---------------------------------------------------------------------- tests/system_tests_protocol_family.py | 22 +++++++++++++++++++--- 1 file changed, 19 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/e605fbd0/tests/system_tests_protocol_family.py ---------------------------------------------------------------------- diff --git a/tests/system_tests_protocol_family.py b/tests/system_tests_protocol_family.py index 0a3182b..6a4cb89 100644 --- a/tests/system_tests_protocol_family.py +++ b/tests/system_tests_protocol_family.py @@ -103,22 +103,38 @@ class ProtocolFamilyTest(TestCase): ('connector', {'addr': '127.0.0.1', 'role': 'inter-router', 'port': inter_router_ipv4_port}) ] ) - cls.routers[0].wait_router_connected('QDR.B') cls.routers[1].wait_router_connected('QDR.A') cls.routers[2].wait_router_connected('QDR.B') # Without at least one test the setUpClass does not execute - def test_00_discard(self): + # If this test has started executing, it means that the setUpClass() has successfully executed which means that + # the routers were able to communicate with each other successfully using the specified protocol family. + def test_simple_pre_settled(self): addr = self.routers[0].addresses[4]+"/test/1" - print 'addr', addr M1 = self.messenger() + M2 = self.messenger() + + M1.start() + M2.start() + M2.subscribe(addr) + tm = Message() + rm = Message() + tm.address = addr for i in range(100): tm.body = {'number': i} M1.put(tm) M1.send() + for i in range(100): + M2.recv(1) + M2.get(rm) + self.assertEqual(i, rm.body['number']) + + M1.stop() + M2.stop() + if __name__ == '__main__': unittest.main(main_module()) \ No newline at end of file --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
