wow-core/me.ahoo.wow.event/NoOpDomainEventBus

NoOpDomainEventBus

object NoOpDomainEventBus : DomainEventBus

No-operation implementation of DomainEventBus.

This implementation provides a no-op (no operation) domain event bus that discards all sent messages and returns empty streams for receive operations. Useful for testing or when event publishing is disabled.

Properties

topicKind

open override val topicKind: TopicKind

Functions

open override fun close()

Closes the message bus and releases any resources. Default implementation does nothing.

receive

open override fun receive(subscription: MessageSubscription): Flux<EventStreamExchange>

Receives domain event streams but returns an empty flux.

receiver

open fun receiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

Creates a single message source with an explicit transport readiness boundary.

runtimeReceiver

open fun runtimeReceiver(subscription: MessageSubscription): MessageReceiver<EventStreamExchange>

Creates the message source owned by a me.ahoo.wow.runtime.WowRuntime dispatcher.

send

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

Sends a domain event stream but performs no operation.

NoOpDomainEventBus

See also

Properties

Functions