Package com.azure.spring.messaging.checkpoint

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
    Mono<Void>
    failure()
    Acknowledge failure of current message.
    Mono<Void>
    success()
    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