Repository: qpid-dispatch Updated Branches: refs/heads/master eefc9fa72 -> 16b44b773
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/16b44b77 Tree: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/tree/16b44b77 Diff: http://git-wip-us.apache.org/repos/asf/qpid-dispatch/diff/16b44b77 Branch: refs/heads/master Commit: 16b44b7738d01f090771b34e2493fc65e32f5d94 Parents: eefc9fa 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:47:09 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/16b44b77/tests/system_tests_link_routes.py ---------------------------------------------------------------------- diff --git a/tests/system_tests_link_routes.py b/tests/system_tests_link_routes.py index 77844d6..1c080cf 100644 --- a/tests/system_tests_link_routes.py +++ b/tests/system_tests_link_routes.py @@ -476,6 +476,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) @@ -511,6 +512,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 @@ -546,7 +548,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