handle

open override fun handle(exchange: DomainEventExchange<*>): Mono<Void>

Handles a domain event exchange for saga processing and collects metrics on the operation. Metrics collected include timing, success/failure rates, and tags for aggregate, event, and processor identification.

Return

a Mono that completes when the saga is handled

Parameters

exchange

the domain event exchange containing the event to process

Throws

if the event function cannot be retrieved from the exchange