This is an automated email from the ASF dual-hosted git repository.
gmurthy pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
The following commit(s) were added to refs/heads/main by this push:
new ff11223 DISPATCH-2023: Set self.reactor in on_start. This closes
#1103.
ff11223 is described below
commit ff11223b49eaf3fcf1e8f693d40ec836d01f0264
Author: Ganesh Murthy <[email protected]>
AuthorDate: Sun Apr 4 21:28:06 2021 -0400
DISPATCH-2023: Set self.reactor in on_start. This closes #1103.
---
tests/system_tests_edge_router.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/tests/system_tests_edge_router.py
b/tests/system_tests_edge_router.py
index b22d61d..d99664a 100644
--- a/tests/system_tests_edge_router.py
+++ b/tests/system_tests_edge_router.py
@@ -2594,6 +2594,7 @@ class MobileAddressMulticastTest(MessagingHandler):
local_node.close()
def on_start(self, event):
+ self.reactor = event.reactor
self.timer = event.reactor.schedule(TIMEOUT, TestTimeout(self))
# Create two receivers
self.receiver1_conn = event.container.connect(self.receiver1_host)
@@ -2613,7 +2614,6 @@ class MobileAddressMulticastTest(MessagingHandler):
event.receiver == self.receiver3:
self.r_attaches += 1
if self.r_attaches == 3:
- self.reactor = event.reactor
self.addr_timer = self.reactor.schedule(1.0, AddrTimer(self))
def on_sendable(self, event):
@@ -2794,6 +2794,7 @@ class MobileAddressEventTest(MessagingHandler):
self.max_attempts = 5
self.num_attempts = 0
self.check_remote = check_remote
+ self.reactor = None
def timeout(self):
if self.dup_msg:
@@ -2842,6 +2843,7 @@ class MobileAddressEventTest(MessagingHandler):
self.timeout()
def on_start(self, event):
+ self.reactor = event.reactor
self.timer = event.reactor.schedule(TIMEOUT, TestTimeout(self))
# Create two receivers
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
