Fix Java pause/resume docs example to finish with resume akka#557

ihostage · May 13, 2021 · 903ed31 · 903ed31
1 parent ac9ddd9
commit 903ed31
Showing 1 changed file with 22 additions and 37 deletions.
diff --git a/examples/src/it/java/jdocs/cassandra/CassandraProjectionDocExample.java b/examples/src/it/java/jdocs/cassandra/CassandraProjectionDocExample.java
@@ -4,70 +4,55 @@
 
 package jdocs.cassandra;
 
-import java.time.Duration;
-
 import akka.Done;
 import akka.NotUsed;
 import akka.actor.typed.ActorRef;
 import akka.actor.typed.ActorSystem;
 import akka.actor.typed.javadsl.ActorContext;
 import akka.actor.typed.javadsl.Behaviors;
-import akka.projection.ProjectionContext;
-import akka.stream.javadsl.FlowWithContext;
-import jdocs.eventsourced.ShoppingCart;
-
-// #daemon-imports
 import akka.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
-import akka.projection.ProjectionBehavior;
-
-// #daemon-imports
-
-// #singleton-imports
 import akka.cluster.typed.ClusterSingleton;
 import akka.cluster.typed.SingletonActor;
-
-// #singleton-imports
-
-// #source-provider-imports
 import akka.persistence.cassandra.query.javadsl.CassandraReadJournal;
 import akka.persistence.query.Offset;
-import akka.projection.javadsl.SourceProvider;
-import akka.projection.eventsourced.javadsl.EventSourcedProvider;
-import akka.projection.eventsourced.EventEnvelope;
-
-// #source-provider-imports
-
-// #projection-imports
-import akka.projection.cassandra.javadsl.CassandraProjection;
+import akka.persistence.query.Sequence;
+import akka.projection.HandlerRecoveryStrategy;
 import akka.projection.Projection;
+import akka.projection.ProjectionBehavior;
+import akka.projection.ProjectionContext;
 import akka.projection.ProjectionId;
-
-// #projection-imports
-
-// #handler-imports
+import akka.projection.cassandra.javadsl.CassandraProjection;
+import akka.projection.eventsourced.EventEnvelope;
+import akka.projection.eventsourced.javadsl.EventSourcedProvider;
 import akka.projection.javadsl.Handler;
+import akka.projection.javadsl.ProjectionManagement;
+import akka.projection.javadsl.SourceProvider;
+import akka.stream.javadsl.FlowWithContext;
+import jdocs.eventsourced.ShoppingCart;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.time.Duration;
 import java.util.List;
 import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;
 
+// #daemon-imports
+// #daemon-imports
+// #singleton-imports
+// #singleton-imports
+// #source-provider-imports
+// #source-provider-imports
+// #projection-imports
+// #projection-imports
+// #handler-imports
 // #handler-imports
-
 // #withRecoveryStrategy
-import akka.projection.HandlerRecoveryStrategy;
-
 // #withRecoveryStrategy
-
 // #get-offset
-import akka.projection.javadsl.ProjectionManagement;
-
 // #get-offset
-
 // #update-offset
-import akka.persistence.query.Sequence;
 
 // #update-offset
 
@@ -409,7 +394,7 @@ public static void illustratPauseResume() {
     ProjectionManagement mgmt = ProjectionManagement.get(system);
     CompletionStage<Done> pauseDone = mgmt.pause(projectionId);
     CompletionStage<Done> migrationDone = pauseDone.thenCompose(notUsed -> someDataMigration());
-    CompletionStage<Done> resumeDone = migrationDone.thenCompose(notUsed -> mgmt.pause(projectionId));
+    CompletionStage<Done> resumeDone = migrationDone.thenCompose(notUsed -> mgmt.resume(projectionId));
     // #pause-resume
   }