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

LocalFirstMessageBus

interface LocalFirstMessageBus<M : Message<*, *>, NamedAggregate, Copyable<*>, E : MessageExchange<*, M>> : MessageBus<M, E>

Inheritors

LocalFirstCommandBus

LocalFirstDomainEventBus

LocalFirstStateEventBus

Properties

abstract val distributedBus: DistributedMessageBus<M, E>

abstract val localBus: LocalMessageBus<M, E>

Functions

open override fun close()

open override fun receive(namedAggregates: Set<NamedAggregate>): Flux<E>

open override fun send(message: M): Mono<Void>