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.

Properties

LOCAL_FIRST_HEADER

const val LOCAL_FIRST_HEADER: String

Header key used to indicate local-first message routing.

RECEIVER_GROUP

const val RECEIVER_GROUP: String

Constant key used to store the receiver group in Reactor context.

Functions

getReceiverGroup

fun ContextView.getReceiverGroup(): String

Retrieves the receiver group from the Reactor context.

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.

setReceiverGroup

fun Context.setReceiverGroup(receiverGroup: String): Context

Sets the receiver group in the Reactor context.

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.

writeReceiverGroup

fun <T : Any> Flux<T>.writeReceiverGroup(receiverGroup: String): Flux<T>

Writes the receiver group to the Reactor context for this Flux.