Interface Checkpointer


public interface Checkpointer
A callback to perform checkpoint for received messages. When a manual checkpoint mode is used in Event Hubs or autoComplete is set to false in Service Bus, Checkpointer will be put in messages as the header AzureHeaders.CHECKPOINTER.

Example


 Checkpointer checkpointer = message.getHeaders().get(AzureHeaders.CHECKPOINTER, Checkpointer.class);
 checkpointer.success()
             .doOnSuccess(success -> LOGGER.info("Successfully checkpoint {}", message.getPayload()))
             .doOnError(e -> LOGGER.error("Fail to checkpoint the message", e))
             .block();
 
  • Method Summary

    Modifier and Type
    Method
    Description
    Acknowledge failure of current message.
    Acknowledge success of current message.
  • Method Details

    • success

      Mono<Void> success()
      Acknowledge success of current message. Please check result to detect failure
      Returns:
      Mono Void
    • failure

      Mono<Void> failure()
      Acknowledge failure of current message. Please check result to detect failure
      Returns:
      Mono Void