File tree 1 file changed +10
-5
lines changed
atomix/cluster/src/main/java/io/atomix/raft/impl
1 file changed +10
-5
lines changed Original file line number Diff line number Diff line change @@ -477,12 +477,17 @@ public void addSnapshotReplicationListener(
477
477
// Notify listener immediately if it registered during an ongoing replication.
478
478
// This is to prevent missing necessary state transitions.
479
479
switch (missedSnapshotReplicationEvents ) {
480
- case STARTED -> snapshotReplicationListener .onSnapshotReplicationStarted ();
481
- case COMPLETED -> {
480
+ case STARTED :
482
481
snapshotReplicationListener .onSnapshotReplicationStarted ();
483
- snapshotReplicationListener .onSnapshotReplicationCompleted (term );
484
- }
485
- default -> {}
482
+ break ;
483
+ case COMPLETED :
484
+ {
485
+ snapshotReplicationListener .onSnapshotReplicationStarted ();
486
+ snapshotReplicationListener .onSnapshotReplicationCompleted (term );
487
+ break ;
488
+ }
489
+ default :
490
+ break ;
486
491
}
487
492
});
488
493
}
You can’t perform that action at this time.
0 commit comments