receive

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

Receives command exchanges for the specified named aggregates and collects metrics on the operation. Metrics collected include timing and tags for aggregate identification and subscriber information.

Return

a Flux of server command exchanges

Parameters

subscription

the message subscription