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 2019/09/30 23:02:26 UTC
[qpid-dispatch] branch master updated: DISPATCH-1433 - Wait for the
receivers to get created before starting to send messages to them
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 <gm...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org