Interface Checkpointer

  • Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

    @FunctionalInterface
    public interface Checkpointer
    Callback type when a checkpoint is reached.
    • Method Detail

      • onCheckpoint

        java.util.concurrent.CompletableFuture<java.lang.Void> onCheckpoint​(Subscription subscription,
                                                                            Position position)
        Called everytime a checkpoint is reached.
        Parameters:
        subscription - Subscription handle.
        position - Transaction log position.