From 55601c66df651427c053e0a0d4dce5179b9b8564 Mon Sep 17 00:00:00 2001 From: He-Pin Date: Tue, 8 Aug 2023 20:13:14 +0800 Subject: [PATCH] =test Reschedule the reconnect when exception caught. Signed-off-by: He-Pin --- .../scala/org/apache/pekko/remote/testconductor/Player.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Player.scala b/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Player.scala index 3977a8b7dc..7dcaa10a8d 100644 --- a/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Player.scala +++ b/multi-node-testkit/src/main/scala/org/apache/pekko/remote/testconductor/Player.scala @@ -352,6 +352,7 @@ private[pekko] class PlayerHandler( cause match { case _: ConnectException if reconnects > 0 => reconnects -= 1 + scheduleReconnect() case e => fsm ! ConnectionFailure(e.getMessage) } }