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

SendDomainEventStreamFilter

@Order(value = 2147483647, after = [AggregateProcessorFilter::class])
class SendDomainEventStreamFilter(domainEventBus: DomainEventBus) : ExchangeFilter<ServerCommandExchange<*>>

Constructors

Link copied to clipboard
constructor(domainEventBus: DomainEventBus)

Functions

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