compensate

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

Compensates an event stream by marking it for compensation and resending.

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

Return

A Mono that completes when the compensated event is sent

Parameters

eventStream

The event stream to compensate

target

The compensation target specifying the compensation context

See also

DomainEventStream.withCompensation