receiveMessage

abstract fun receiveMessage(namedAggregate: NamedAggregate): Flux<T>