SimpleStateEventExchange

class SimpleStateEventExchange<S : Any>(val message: StateEvent<S>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<S>

Simple implementation of StateEventExchange using a concurrent hash map for attributes. Provides thread-safe attribute storage for message processing.

Parameters

message

The state event message being processed.

attributes

Mutable map for storing processing attributes (default: empty ConcurrentHashMap).

Type Parameters

S

The type of the state in the state event.

Constructors

Link copied to clipboard
constructor(message: StateEvent<S>, attributes: MutableMap<String, Any> = ConcurrentHashMap())

Properties

Link copied to clipboard
open override val attributes: MutableMap<String, Any>
Link copied to clipboard
open override val message: StateEvent<S>