receive

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>