Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
seglo opened this issue May 13, 2021 · 0 comments
Open

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

seglo opened this issue May 13, 2021 · 0 comments

Comments

@seglo
Copy link
Member

seglo commented May 13, 2021

Reported by @mckeeh3

https://doc.akka.io/docs/akka-projection/current/management.html?_ga=2.226035482.1601428721.1620908416-167537786.1584038307#pause-and-resume

ProjectionId projectionId = ProjectionId.of("shopping-carts", "carts-1");
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));

Last line should be

CompletionStage<Done> resumeDone = migrationDone.thenCompose(notUsed -> mgmt.resume(projectionId));
ihostage added a commit to ihostage/akka-projection that referenced this issue May 13, 2021
ihostage added a commit to ihostage/akka-projection that referenced this issue May 13, 2021
patriknw added a commit that referenced this issue May 14, 2021
Fix Java pause/resume docs example to finish with resume #557
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant