Package com.azure.spring.messaging.checkpoint

Class AzureCheckpointer

java.lang.Object

com.azure.spring.messaging.checkpoint.AzureCheckpointer

All Implemented Interfaces:

Checkpointer

public class AzureCheckpointer
extends Object
implements Checkpointer

Azure implementation for check point callback.

Constructor Summary

Constructors

Constructor	Description
AzureCheckpointer(Supplier<Mono<Void>> success)	Construct the checkpointer with the Supplier for a success operation.
AzureCheckpointer(Supplier<Mono<Void>> success, Supplier<Mono<Void>> fail)	Construct the checkpointer with Suppliers for a success operation and failure operation.

Method Summary

Modifier and Type	Method	Description
Mono<Void>	failure()	Acknowledge failure of current message.
Mono<Void>	success()	Acknowledge success of current message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AzureCheckpointer

public AzureCheckpointer(@NonNull
 Supplier<Mono<Void>> success)

Construct the checkpointer with the Supplier for a success operation.

Parameters:

success - the Supplier for a success operation.

AzureCheckpointer

public AzureCheckpointer(@NonNull
 Supplier<Mono<Void>> success,
 Supplier<Mono<Void>> fail)

Construct the checkpointer with Suppliers for a success operation and failure operation.

Parameters:

success - the Supplier for a success operation.

fail - the Supplier for a failure operation.

Method Details

success

public Mono<Void> success()

Description copied from interface: Checkpointer

Acknowledge success of current message. Please check result to detect failure

Specified by:

success in interface Checkpointer

Returns:

Mono Void

failure

public Mono<Void> failure()

Description copied from interface: Checkpointer

Acknowledge failure of current message. Please check result to detect failure

Specified by:

failure in interface Checkpointer

Returns:

Mono Void