From 1a6057eeb5bf47e3276cf919acf6085e75c50b05 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Thu, 14 Apr 2016 11:36:24 +0200 Subject: [PATCH] increase delay before shutting down persistence samples, #20005 --- .../main/java/sample/persistence/PersistentActorExample.java | 2 +- .../java/sample/persistence/PersistentActorFailureExample.java | 2 +- .../src/main/java/sample/persistence/SnapshotExample.java | 2 +- .../main/java/sample/persistence/PersistentActorExample.java | 2 +- .../java/sample/persistence/PersistentActorFailureExample.java | 2 +- .../src/main/java/sample/persistence/SnapshotExample.java | 2 +- .../main/scala/sample/persistence/PersistentActorExample.scala | 2 +- .../sample/persistence/PersistentActorFailureExample.scala | 2 +- .../src/main/scala/sample/persistence/SnapshotExample.scala | 2 +- 9 files changed, 9 insertions(+), 9 deletions(-) diff --git a/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/PersistentActorExample.java b/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/PersistentActorExample.java index b4fc9e9134..7f41d001dd 100644 --- a/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/PersistentActorExample.java +++ b/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/PersistentActorExample.java @@ -127,7 +127,7 @@ public class PersistentActorExample { persistentActor.tell(new Cmd("buzz"), null); persistentActor.tell("print", null); - Thread.sleep(1000); + Thread.sleep(10000); system.terminate(); } } diff --git a/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/PersistentActorFailureExample.java b/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/PersistentActorFailureExample.java index 3431489f2a..cc9bacd4b3 100644 --- a/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/PersistentActorFailureExample.java +++ b/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/PersistentActorFailureExample.java @@ -71,7 +71,7 @@ public class PersistentActorFailureExample { // etc ... - Thread.sleep(1000); + Thread.sleep(10000); system.terminate(); } } diff --git a/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/SnapshotExample.java b/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/SnapshotExample.java index e99837984c..fcfa75e298 100644 --- a/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/SnapshotExample.java +++ b/akka-samples/akka-sample-persistence-java-lambda/src/main/java/sample/persistence/SnapshotExample.java @@ -88,7 +88,7 @@ public class SnapshotExample { persistentActor.tell("d", null); persistentActor.tell("print", null); - Thread.sleep(1000); + Thread.sleep(10000); system.terminate(); } } diff --git a/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/PersistentActorExample.java b/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/PersistentActorExample.java index c126dac949..62a924ffbf 100644 --- a/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/PersistentActorExample.java +++ b/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/PersistentActorExample.java @@ -129,7 +129,7 @@ public class PersistentActorExample { persistentActor.tell(new Cmd("buzz"), null); persistentActor.tell("print", null); - Thread.sleep(1000); + Thread.sleep(10000); system.terminate(); } } diff --git a/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/PersistentActorFailureExample.java b/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/PersistentActorFailureExample.java index 94654db5f3..291ee55c93 100644 --- a/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/PersistentActorFailureExample.java +++ b/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/PersistentActorFailureExample.java @@ -70,7 +70,7 @@ public class PersistentActorFailureExample { // etc ... - Thread.sleep(1000); + Thread.sleep(10000); system.terminate(); } } diff --git a/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/SnapshotExample.java b/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/SnapshotExample.java index 789bbc9fba..0c1ed7cac0 100644 --- a/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/SnapshotExample.java +++ b/akka-samples/akka-sample-persistence-java/src/main/java/sample/persistence/SnapshotExample.java @@ -95,7 +95,7 @@ public class SnapshotExample { persistentActor.tell("d", null); persistentActor.tell("print", null); - Thread.sleep(1000); + Thread.sleep(10000); system.terminate(); } } diff --git a/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/PersistentActorExample.scala b/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/PersistentActorExample.scala index 45ea16f9b6..12e170b0a0 100644 --- a/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/PersistentActorExample.scala +++ b/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/PersistentActorExample.scala @@ -55,6 +55,6 @@ object PersistentActorExample extends App { persistentActor ! Cmd("buzz") persistentActor ! "print" - Thread.sleep(1000) + Thread.sleep(10000) system.terminate() } diff --git a/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/PersistentActorFailureExample.scala b/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/PersistentActorFailureExample.scala index 56b57cd1af..387429e9f5 100644 --- a/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/PersistentActorFailureExample.scala +++ b/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/PersistentActorFailureExample.scala @@ -48,6 +48,6 @@ object PersistentActorFailureExample extends App { // etc ... - Thread.sleep(1000) + Thread.sleep(10000) system.terminate() } diff --git a/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/SnapshotExample.scala b/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/SnapshotExample.scala index 9d3c6b7ae6..3a9b1a03ce 100644 --- a/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/SnapshotExample.scala +++ b/akka-samples/akka-sample-persistence-scala/src/main/scala/sample/persistence/SnapshotExample.scala @@ -43,6 +43,6 @@ object SnapshotExample extends App { persistentActor ! "d" persistentActor ! "print" - Thread.sleep(1000) + Thread.sleep(10000) system.terminate() }