compensate

open override fun compensate(eventStream: StateEvent<*>, target: CompensationTarget): Mono<Void>

Compensates a state event by marking it for compensation and resending.

This method applies compensation metadata to the state event and publishes it to the state event bus for reprocessing.

Return

A Mono that completes when the compensated event is sent

Parameters

eventStream

The state event to compensate

target

The compensation target specifying the compensation context

See also

StateEvent.withCompensation