finallyAck

fun Mono<*>.finallyAck(exchange: MessageExchange<*, *>): Mono<Void>

Ensures the exchange is acknowledged after Mono completion, even on error.

If the Mono fails, acknowledges first, then re-throws the error. If successful, acknowledges after completion.

Return

A Mono that acknowledges the exchange

Parameters

exchange

The exchange to acknowledge


fun Flux<*>.finallyAck(exchange: MessageExchange<*, *>): Mono<Void>

Ensures the exchange is acknowledged after Flux completion, even on error.

If the Flux fails, acknowledges first, then re-throws the error. If successful, acknowledges after completion.

Return

A Mono that acknowledges the exchange

Parameters

exchange

The exchange to acknowledge