This is an automated email from the ASF dual-hosted git repository. gmurthy pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/master by this push: new c3fd202 DISPATCH-1433 - Wait for the receivers to get created before starting to send messages to them c3fd202 is described below commit c3fd202f5ce17cb553ea3fc4b04cde376fe86e5b Author: Ganesh Murthy <gmur...@apache.org> AuthorDate: Mon Sep 30 19:01:53 2019 -0400 DISPATCH-1433 - Wait for the receivers to get created before starting to send messages to them --- tests/system_tests_delivery_abort.py | 24 +++++++++++++++++++++--- 1 file changed, 21 insertions(+), 3 deletions(-) diff --git a/tests/system_tests_delivery_abort.py b/tests/system_tests_delivery_abort.py index 9b7418b..47585ee 100644 --- a/tests/system_tests_delivery_abort.py +++ b/tests/system_tests_delivery_abort.py @@ -480,6 +480,8 @@ class MulticastTruncateTest(MessagingHandler): self.receiver_host1 = receiver_host1 self.receiver_host2 = receiver_host2 self.address = address + self.r_attach_count = 0 + self.senders_created = False self.sender_conn = None self.receiver1_conn = None @@ -515,9 +517,6 @@ class MulticastTruncateTest(MessagingHandler): self.sender_conn = event.container.connect(self.sender_host) self.receiver1_conn = event.container.connect(self.receiver_host1) self.receiver2_conn = event.container.connect(self.receiver_host2) - self.sender1 = event.container.create_sender(self.sender_conn, self.address, name="S1") - self.sender2 = event.container.create_sender(self.sender_conn, self.address, name="S2") - self.sender3 = event.container.create_sender(self.sender_conn, self.address, name="S3") self.receiver1 = event.container.create_receiver(self.receiver1_conn, self.address) self.receiver2 = event.container.create_receiver(self.receiver2_conn, self.address) @@ -537,6 +536,7 @@ class MulticastTruncateTest(MessagingHandler): if next_op == 'Send_Short_1': m = Message(body="%s" % next_op) self.sender1.send(m) + elif next_op == 'Send_Long_Truncated': for i in range(100): self.long_data += self.data @@ -561,6 +561,24 @@ class MulticastTruncateTest(MessagingHandler): def on_sendable(self, event): self.send() + def on_link_opened(self, event): + if event.receiver == self.receiver1: + self.r_attach_count += 1 + + if event.receiver == self.receiver2: + self.r_attach_count += 1 + + if self.r_attach_count == 2 and not self.senders_created: + self.senders_created = True + self.sender1 = event.container.create_sender(self.sender_conn, + self.address, + name="S1") + self.sender2 = event.container.create_sender(self.sender_conn, + self.address, + name="S2") + self.sender3 = event.container.create_sender(self.sender_conn, + self.address, + name="S3") def on_message(self, event): m = event.message if event.receiver == self.receiver1: --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org