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/01/02 19:02:26 UTC
[qpid-dispatch] branch master updated: DISPATCH-1233 - Modified
tests to create the senders after the receiver links have been opened
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 049b97b DISPATCH-1233 - Modified tests to create the senders after the receiver links have been opened
049b97b is described below
commit 049b97b47cdde3d41ac6af77ede70dd35b0a550f
Author: Ganesh Murthy <gm...@redhat.com>
AuthorDate: Wed Jan 2 14:02:11 2019 -0500
DISPATCH-1233 - Modified tests to create the senders after the receiver links have been opened
---
tests/system_tests_global_delivery_counts.py | 14 ++++++++------
1 file changed, 8 insertions(+), 6 deletions(-)
diff --git a/tests/system_tests_global_delivery_counts.py b/tests/system_tests_global_delivery_counts.py
index 7ab1a58..8ab93ac 100644
--- a/tests/system_tests_global_delivery_counts.py
+++ b/tests/system_tests_global_delivery_counts.py
@@ -495,10 +495,8 @@ class IngressEgressTwoRouterTest(MessagingHandler):
def on_start(self, event):
self.timer = event.reactor.schedule(TIMEOUT, Timeout(self))
- self.conn_sender = event.container.connect(self.address1)
self.conn_recv = event.container.connect(self.address2)
self.receiver = event.container.create_receiver(self.conn_recv, self.dest)
- self.sender = event.container.create_sender(self.conn_sender, self.dest)
def on_sendable(self, event):
if not self.start:
@@ -512,6 +510,9 @@ class IngressEgressTwoRouterTest(MessagingHandler):
def on_link_opened(self, event):
if event.receiver == self.receiver:
self.start = True
+ self.conn_sender = event.container.connect(self.address1)
+ self.sender = event.container.create_sender(self.conn_sender,
+ self.dest)
def on_message(self, event):
if event.receiver == self.receiver:
@@ -597,8 +598,6 @@ class RouteContainerEgressTest(MessagingHandler):
self.timer = event.reactor.schedule(TIMEOUT, Timeout(self))
self.receiver_conn = event.container.connect(self.route_container_addr)
self.receiver = event.container.create_receiver(self.receiver_conn, self.dest)
- self.sender_conn = event.container.connect(self.sender_addr)
- self.sender = event.container.create_sender(self.sender_conn, self.dest)
def timeout(self):
self.error = "Timeout Expired: self.n_sent=%d self.n_received=%d" % (self.n_sent, self.self.n_received)
@@ -624,6 +623,8 @@ class RouteContainerEgressTest(MessagingHandler):
def on_link_opened(self, event):
if event.receiver == self.receiver:
self.start = True
+ self.sender_conn = event.container.connect(self.sender_addr)
+ self.sender = event.container.create_sender(self.sender_conn, self.dest)
def run(self):
Container(self).run()
@@ -726,11 +727,12 @@ class IngressEgressTransitLinkRouteTest(MessagingHandler):
self.timer = event.reactor.schedule(TIMEOUT, Timeout(self))
self.receiver_conn = event.container.connect(self.receiver_addr)
self.receiver = event.container.create_receiver(self.receiver_conn, self.dest)
- self.sender_conn = event.container.connect(self.sender_addr)
- self.sender = event.container.create_sender(self.sender_conn, self.dest)
def on_link_opened(self, event):
if event.receiver == self.receiver:
+ self.sender_conn = event.container.connect(self.sender_addr)
+ self.sender = event.container.create_sender(self.sender_conn,
+ self.dest)
self.start = True
def on_sendable(self, event):
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org