wow-core/me.ahoo.wow.eventsourcing.state/LocalFirstStateEventBus

LocalFirstStateEventBus

class LocalFirstStateEventBus(val distributedBus: DistributedStateEventBus, val localBus: LocalStateEventBus = InMemoryStateEventBus()) : StateEventBus, LocalFirstMessageBus<StateEvent<*>, StateEventExchange<*>>

Constructors

LocalFirstStateEventBus

constructor(distributedBus: DistributedStateEventBus, localBus: LocalStateEventBus = InMemoryStateEventBus())

Properties

open override val distributedBus: DistributedStateEventBus

open override val localBus: LocalStateEventBus

open override val topicKind: TopicKind

Functions

open override fun close()

abstract fun receive(namedAggregates: Set<NamedAggregate>): Flux<StateEventExchange<*>>

abstract fun send(message: StateEvent<*>): Mono<Void>