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

Package-level declarations

Types

CommandOperatorMessagePropagator

class CommandOperatorMessagePropagator : MessagePropagator

Propagator that copies command operator information from upstream messages.

CommandRequestHeaderPropagator

class CommandRequestHeaderPropagator(enabled: Boolean = true) : MessagePropagator

Propagator that copies request-related headers like user agent and remote IP.

MessagePropagator

interface MessagePropagator

Interface for message propagators that transfer context information from upstream messages to headers.

MessagePropagators

class MessagePropagators(propagators: List<MessagePropagator>)

The header propagation of one runtime: the propagators it runs, in @Order, whenever a message is derived from an upstream one (an event stream from its command, a command from the event a saga reacts to).

TraceMessagePropagator

class TraceMessagePropagator : MessagePropagator

Propagator that handles trace ID and upstream information propagation.

WaitPlanMessagePropagator

class WaitPlanMessagePropagator : MessagePropagator

Propagates command wait plan headers from upstream messages.

Functions

propagate

fun Header.propagate(upstream: Message<*, *>, propagators: MessagePropagators = MessagePropagators.DEFAULT): Header

Propagates upstream's context to this header with propagators, and returns this header.