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 Header implementation.

DistributedMessageBus

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

InMemoryMessageBus

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

LocalFirstMessageBus

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

LocalMessageBus

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

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

MessageDispatcher

interface MessageDispatcher : Runnable, AutoCloseable, Named

Properties

LOCAL_FIRST_HEADER

const val LOCAL_FIRST_HEADER: String

const val RECEIVER_GROUP: String

Functions

getReceiverGroup

fun ContextView.getReceiverGroup(): String

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

fun Header.isLocalFirst(): Boolean

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

setReceiverGroup

fun Context.setReceiverGroup(receiverGroup: String): Context

shouldLocalFirst

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

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

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

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

writeReceiverGroup

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

Write Receiver Group.