invoke

open operator override fun invoke(exchange: DomainEventExchange<*>): Mono<CommandStream>