DISPATCH-443 - Updated tag test to handle increase in connection rate associated with this fix.
Project: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/commit/e1909555 Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/e1909555 Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/e1909555 Branch: refs/heads/0.6.x Commit: e1909555b9b95dcfaa997e8c4fe9845315675a57 Parents: cf3c874 Author: Ted Ross <tr...@redhat.com> Authored: Thu Jul 7 15:47:09 2016 -0400 Committer: Ted Ross <tr...@redhat.com> Committed: Thu Jul 7 15:51:56 2016 -0400 ---------------------------------------------------------------------- tests/system_tests_link_routes.py | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-dispatch/blob/e1909555/tests/system_tests_link_routes.py ---------------------------------------------------------------------- diff --git a/tests/system_tests_link_routes.py b/tests/system_tests_link_routes.py index b3dbac2..a251d42 100644 --- a/tests/system_tests_link_routes.py +++ b/tests/system_tests_link_routes.py @@ -437,6 +437,7 @@ class LinkRoutePatternTest(TestCase): qdstat_address = self.routers[2].addresses[0] test = DeliveryTagsTest(sender_address, listening_address, qdstat_address) test.run() + self.assertTrue(test.wait_completed) self.assertTrue(test.message_received) self.assertTrue(test.delivery_tag_verified) @@ -472,6 +473,7 @@ class DeliveryTagsTest(MessagingHandler): self.sender_address = sender_address self.listening_address = listening_address self.sender = None + self.wait_completed = False self.message_received = False self.receiver_connection = None self.sender_connection = None @@ -507,7 +509,9 @@ class DeliveryTagsTest(MessagingHandler): if out == 1: continue_loop = False i+=1 + sleep(0.25) + self.wait_completed = True self.sender_connection = event.container.connect(self.sender_address) self.sender = event.container.create_sender(self.sender_connection, "pulp.task", options=AtMostOnce()) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
