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

InMemoryMessageBus

abstract class InMemoryMessageBus<M : Message<*, *>, NamedAggregate, E : MessageExchange<*, M>> : LocalMessageBus<M, E>

Inheritors

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
abstract val sinkSupplier: (NamedAggregate) -> Sinks.Many<M>

Functions

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