This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 55601c66df =test Reschedule the reconnect when exception caught.
55601c66df is described below
commit 55601c66df651427c053e0a0d4dce5179b9b8564
Author: He-Pin <[email protected]>
AuthorDate: Tue Aug 8 20:13:14 2023 +0800
=test Reschedule the reconnect when exception caught.
Signed-off-by: He-Pin <[email protected]>
---
.../src/main/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)
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
