receiveMessage

open override fun receiveMessage(namedAggregate: NamedAggregate): Flux<ServerCommandExchange<*>>