=test Reschedule the reconnect when exception caught.

Signed-off-by: He-Pin <hepin1989@gmail.com>
2023-08-08 20:13:14 +08:00 · 2023-08-08 20:13:14 +08:00 · 55601c66df
commit 55601c66df
parent 262d485d56
1 changed files with 1 additions and 0 deletions
--- 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)
    }
  }