From 75f044a0d0f2664f581b0f35a7db481a40cbb03a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Mon, 2 Jul 2018 15:57:36 +0200 Subject: [PATCH] Don't trigger graceful leave #24728 --- .../src/test/scala/akka/cluster/typed/ClusterApiSpec.scala | 3 +++ 1 file changed, 3 insertions(+) diff --git a/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterApiSpec.scala b/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterApiSpec.scala index ce4e086fcb..d3aaacfd7e 100644 --- a/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterApiSpec.scala +++ b/akka-cluster-typed/src/test/scala/akka/cluster/typed/ClusterApiSpec.scala @@ -32,6 +32,8 @@ object ClusterApiSpec { } # generous timeout for cluster forming probes akka.actor.testkit.typed.default-timeout = 10s + # disable this or we cannot be sure to observe node end state on the leaving side + akka.cluster.run-coordinated-shutdown-when-down = off """) } @@ -93,6 +95,7 @@ class ClusterApiSpec extends ActorTestKit with TypedAkkaSpecWithShutdown with Sc // selfMember updated and self removed event gotten node2Probe.awaitAssert(clusterNode2.selfMember.status should ===(MemberStatus.Removed)) + node2Probe.expectMessage(SelfRemoved(MemberStatus.Exiting)) // subscribing to SelfRemoved when already removed yields immediate message back