wow-core/me.ahoo.wow.modeling.command/SendDomainEventStreamFilter

SendDomainEventStreamFilter

@Order(value = 2147483647, after = [AggregateProcessorFilter::class])

class SendDomainEventStreamFilter(domainEventBus: DomainEventBus) : ExchangeFilter<ServerCommandExchange<*>>

Constructors

SendDomainEventStreamFilter

constructor(domainEventBus: DomainEventBus)

Types

object Companion

Functions

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

Processes the message exchange and optionally calls the next filter in the chain.