filter

open override fun filter(exchange: DomainEventExchange<*>, next: FilterChain<DomainEventExchange<*>>): Mono<Void>

Filters the domain event exchange by invoking the registered event function.

This method sets the service provider on the exchange, retrieves the event function, invokes it, and then continues with the next filter in the chain.

Return

A Mono that completes when the event function and subsequent filters finish

Parameters

exchange

The domain event exchange to process

next

The next filter in the chain

See also

Throws

if no event function is registered for the exchange