diff --git a/akka-multi-node-testkit/src/main/resources/reference.conf b/akka-multi-node-testkit/src/main/resources/reference.conf index 00ee3363d4..6d6010b7f4 100644 --- a/akka-multi-node-testkit/src/main/resources/reference.conf +++ b/akka-multi-node-testkit/src/main/resources/reference.conf @@ -25,7 +25,7 @@ akka { connect-timeout = 20s # Number of connect attempts to be made to the conductor controller - client-reconnects = 10 + client-reconnects = 30 # minimum time interval which is to be inserted between reconnect attempts reconnect-backoff = 1s diff --git a/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Player.scala b/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Player.scala index e772e59056..fc9803afc9 100644 --- a/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Player.scala +++ b/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Player.scala @@ -162,10 +162,11 @@ private[akka] class ClientFSM(name: RoleName, controllerAddr: InetSocketAddress) case Event(Connected(channel), _) ⇒ channel.write(Hello(name.name, TestConductor().address)) goto(AwaitDone) using Data(Some(channel), None) - case Event(_: ConnectionFailure, _) ⇒ + case Event(e: ConnectionFailure, _) ⇒ + log.error(e, "ConnectionFailure") goto(Failed) case Event(StateTimeout, _) ⇒ - log.error("connect timeout to TestConductor") + log.error("Failed to connect to test conductor within {} ms.", settings.ConnectTimeout.toMillis) goto(Failed) }