diff --git a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingGracefulShutdownSpec.scala b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingGracefulShutdownSpec.scala index 70f332ce22..756c6c7678 100644 --- a/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingGracefulShutdownSpec.scala +++ b/akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingGracefulShutdownSpec.scala @@ -56,7 +56,7 @@ object ClusterShardingGracefulShutdownSpec { case "member-removed" ⇒ // Let singletons hand over gracefully before stopping the system import context.dispatcher - system.scheduler.scheduleOnce(3.seconds, self, "stop-system") + system.scheduler.scheduleOnce(10.seconds, self, "stop-system") case "stop-system" ⇒ system.terminate() diff --git a/akka-cluster-sharding/src/test/java/akka/cluster/sharding/ClusterShardingTest.java b/akka-cluster-sharding/src/test/java/akka/cluster/sharding/ClusterShardingTest.java index 61b5efba59..6d0ec7d98a 100644 --- a/akka-cluster-sharding/src/test/java/akka/cluster/sharding/ClusterShardingTest.java +++ b/akka-cluster-sharding/src/test/java/akka/cluster/sharding/ClusterShardingTest.java @@ -204,7 +204,7 @@ public class ClusterShardingTest { }). match(String.class, s -> s.equals("member-removed"), s -> { // Let singletons hand over gracefully before stopping the system - context().system().scheduler().scheduleOnce(Duration.create(3, SECONDS), + context().system().scheduler().scheduleOnce(Duration.create(10, SECONDS), self(), "stop-system", context().dispatcher(), self()); }). match(String.class, s -> s.equals("stop-system"), s -> {