receive

open override fun receive(subscription: MessageSubscription): Flux<E>

Receives messages for the specified named aggregates.

Creates a flux that merges messages from all the sinks corresponding to the named aggregates and converts them to message exchanges.

Return

A flux of message exchanges

Parameters

subscription

The message subscription