receiveMessage

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