raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=cls increase the delay in the graceful shutdown example

Browse source
This commit is contained in:
Patrik Nordwall 2015-12-21 09:54:14 +01:00
parent 290f402b79
commit 5ebdd79bee
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingGracefulShutdownSpec.scala
View file

@ -56,7 +56,7 @@ object ClusterShardingGracefulShutdownSpec {
case "member-removed" ⇒ case "member-removed" ⇒
// Let singletons hand over gracefully before stopping the system // Let singletons hand over gracefully before stopping the system
import context.dispatcher import context.dispatcher
system.scheduler.scheduleOnce(3.seconds, self, "stop-system") system.scheduler.scheduleOnce(10.seconds, self, "stop-system")
case "stop-system" ⇒ case "stop-system" ⇒
system.terminate() system.terminate()

2
akka-cluster-sharding/src/test/java/akka/cluster/sharding/ClusterShardingTest.java
View file

@ -204,7 +204,7 @@ public class ClusterShardingTest {
}). }).
match(String.class, s -> s.equals("member-removed"), s -> { match(String.class, s -> s.equals("member-removed"), s -> {
// Let singletons hand over gracefully before stopping the system // 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()); self(), "stop-system", context().dispatcher(), self());
}). }).
match(String.class, s -> s.equals("stop-system"), s -> { match(String.class, s -> s.equals("stop-system"), s -> {