- private final Procedure<Void> createSnapshotProcedure = new Procedure<Void>() {
- @Override
- public void apply(Void notUsed) {
- cohort.createSnapshot(context.getActor());
- }
- };
-
- private final Procedure<byte[]> applySnapshotProcedure = new Procedure<byte[]>() {
- @Override
- public void apply(byte[] state) {
- cohort.applySnapshot(state);
- }
- };
-
- private Duration snapshotReplyActorTimeout = Duration.create(30, TimeUnit.SECONDS);