debug 2

kgiusti · Jan 23, 2025 · 6d7240e · 6d7240e
1 parent 8e5648c
commit 6d7240e
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/tests/system_tests_one_router.py b/tests/system_tests_one_router.py
@@ -2579,6 +2579,7 @@ def __init__(self, address):
         self.receiver = None
         self.body = ""
         self.aborted = False
+        self.received = 0
         for i in range(20000):
             self.body += "0123456789101112131415"
 
@@ -2611,8 +2612,13 @@ def on_sendable(self, event):
         self.sender_conn.close()
 
     def on_message(self, event):
-        self.timer.cancel()
-        self.receiver_conn.close()
+        self.received += 1
+        if self.received >= 100:
+            self.timer.cancel()
+            self.receiver_conn.close()
+        else:
+            self.sender_conn = event.container.connect(self.address)
+            self.sender = event.container.create_sender(self.sender_conn, self.dest)
 
     def on_aborted(self, event):
         self.aborted = True