wow-core/me.ahoo.wow.messaging.dispatcher/AbstractDispatcher/receiveMessage

receiveMessage

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

Creates a flux of messages for the specified named aggregate.

Return

A flux of messages for the aggregate

Parameters

namedAggregate

The named aggregate to receive messages for