wow-core/me.ahoo.wow.messaging

Package-level declarations

Types

class DefaultHeader(delegate: MutableMap<String, String> = mutableMapOf(), var isReadOnly: Boolean = false) : Header, MutableMap<String, String>

Default implementation of the Header interface.

DistributedMessageBus

interface DistributedMessageBus<M : Message<*, *>, E : MessageExchange<*, M>> : MessageBus<M, E>

A distributed message bus that operates across multiple JVM instances or nodes.

InMemoryMessageBus

@ThreadSafe

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

Abstract base class for in-memory message bus implementations.

LocalFirstMessageBus

interface LocalFirstMessageBus<M : Message<*, *>, NamedAggregate, Copyable<*>, E : MessageExchange<*, M>> : MessageBus<M, E>

A message bus that prioritizes local message handling before distributed routing.

LocalMessageBus

interface LocalMessageBus<M : Message<*, *>, E : MessageExchange<*, M>> : MessageBus<M, E>

A local message bus that operates within a single JVM instance.

MessageBus

interface MessageBus<M : Message<*, *>, E : MessageExchange<*, M>> : AutoCloseable

Represents a message bus for sending and receiving messages in a distributed system.

MessageReceiver

class MessageReceiver<E : Any>(messages: Flux<E>, val readiness: Mono<Void> = Mono.empty(), processingAdmission: () -> Unit = {}, processingQuiescence: () -> Unit = {})

A single message source with separate readiness and processing admission.

MessageSubscription

data class MessageSubscription(val namedAggregates: Set<NamedAggregate>, val receiverGroup: String = DEFAULT_RECEIVER_GROUP)

Describes a message bus subscription.

Properties

LOCAL_FIRST_HEADER

const val LOCAL_FIRST_HEADER: String

Header key used to indicate local-first message routing.

Functions

confirmLocalDelivery

fun MessageExchange<*, *>.confirmLocalDelivery()

Confirms that this receiver synchronously admitted the local exchange.

isLocalFirst

fun <M : Message<*, *>> M.isLocalFirst(): Boolean

Checks if this message has local-first routing enabled.

fun Header.isLocalFirst(): Boolean

Checks if the header has the local-first flag set.

isLocalHandled

fun <M : Message<*, *>, NamedAggregate> M.isLocalHandled(): Boolean

Checks if this message has been handled locally.

rejectLocalDelivery

fun MessageExchange<*, *>.rejectLocalDelivery()

Rejects local-only suppression when this exchange is filtered or cannot be admitted. The distributed copy then remains eligible for processing.

shouldLocalFirst

fun <M : Message<*, *>, NamedAggregate> M.shouldLocalFirst(): Boolean

Determines if this message should use local-first routing.

toHeader

fun Map<String, String>?.toHeader(): Header

Converts a nullable map of strings to a Header instance.

withLocalFirst

fun <M : Message<out M, *>> M.withLocalFirst(localFirst: Boolean = true): M

Sets the local-first flag on this message.

fun Header.withLocalFirst(localFirst: Boolean = true): Header

Adds the local-first flag to the header.