wow-core/me.ahoo.wow.messaging/DistributedMessageBus

DistributedMessageBus

interface DistributedMessageBus<M : Message<*, *>, E : MessageExchange<*, M>> : MessageBus<M, E>

Inheritors

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<E>
Link copied to clipboard
abstract fun send(message: M): Mono<Void>