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

Package-level declarations

Types

Link copied to clipboard
abstract class AbstractDispatcher<T : Any> : MessageDispatcher

Abstract base class for message dispatchers that manage multiple aggregate dispatchers.

Link copied to clipboard
abstract class AbstractMessageDispatcher<T : Any> : SafeSubscriber<T> , MessageDispatcher

Abstract base class for message dispatchers that subscribe to topics.

Link copied to clipboard
abstract class AggregateMessageDispatcher<T : MessageExchange<*, *>> : SafeSubscriber<Void> , MessageDispatcher, NamedAggregateDecorator

Abstract dispatcher for handling message exchanges for a specific aggregate.

Link copied to clipboard
object MessageParallelism

Utility object for calculating message processing parallelism.

Link copied to clipboard
abstract class SafeSubscriber<T : Any> : BaseSubscriber<T> , Named

A safe subscriber that wraps message processing with error handling.

Generated by Dokka
© 2025 Copyright