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(namedAggregates: Set<NamedAggregate>): Flux<EventStreamExchange>

Receives domain event streams but returns an empty flux.

send

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

Sends a domain event stream but performs no operation.

NoOpDomainEventBus

See also

Properties

Functions