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

Delegates the compensated event to StateEventBus.send.