increase delay before shutting down persistence samples, #20005

This commit is contained in:
Patrik Nordwall 2016-04-14 11:36:24 +02:00
parent 66a0aa280d
commit 1a6057eeb5
9 changed files with 9 additions and 9 deletions

View file

@ -127,7 +127,7 @@ public class PersistentActorExample {
persistentActor.tell(new Cmd("buzz"), null); persistentActor.tell(new Cmd("buzz"), null);
persistentActor.tell("print", null); persistentActor.tell("print", null);
Thread.sleep(1000); Thread.sleep(10000);
system.terminate(); system.terminate();
} }
} }

View file

@ -71,7 +71,7 @@ public class PersistentActorFailureExample {
// etc ... // etc ...
Thread.sleep(1000); Thread.sleep(10000);
system.terminate(); system.terminate();
} }
} }

View file

@ -88,7 +88,7 @@ public class SnapshotExample {
persistentActor.tell("d", null); persistentActor.tell("d", null);
persistentActor.tell("print", null); persistentActor.tell("print", null);
Thread.sleep(1000); Thread.sleep(10000);
system.terminate(); system.terminate();
} }
} }

View file

@ -129,7 +129,7 @@ public class PersistentActorExample {
persistentActor.tell(new Cmd("buzz"), null); persistentActor.tell(new Cmd("buzz"), null);
persistentActor.tell("print", null); persistentActor.tell("print", null);
Thread.sleep(1000); Thread.sleep(10000);
system.terminate(); system.terminate();
} }
} }

View file

@ -70,7 +70,7 @@ public class PersistentActorFailureExample {
// etc ... // etc ...
Thread.sleep(1000); Thread.sleep(10000);
system.terminate(); system.terminate();
} }
} }

View file

@ -95,7 +95,7 @@ public class SnapshotExample {
persistentActor.tell("d", null); persistentActor.tell("d", null);
persistentActor.tell("print", null); persistentActor.tell("print", null);
Thread.sleep(1000); Thread.sleep(10000);
system.terminate(); system.terminate();
} }
} }

View file

@ -55,6 +55,6 @@ object PersistentActorExample extends App {
persistentActor ! Cmd("buzz") persistentActor ! Cmd("buzz")
persistentActor ! "print" persistentActor ! "print"
Thread.sleep(1000) Thread.sleep(10000)
system.terminate() system.terminate()
} }

View file

@ -48,6 +48,6 @@ object PersistentActorFailureExample extends App {
// etc ... // etc ...
Thread.sleep(1000) Thread.sleep(10000)
system.terminate() system.terminate()
} }

View file

@ -43,6 +43,6 @@ object SnapshotExample extends App {
persistentActor ! "d" persistentActor ! "d"
persistentActor ! "print" persistentActor ! "print"
Thread.sleep(1000) Thread.sleep(10000)
system.terminate() system.terminate()
} }