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
Delegates the compensated stream to DomainEventBus.send.