Package-level declarations

Distributed state event bus that handles message routing across multiple instances or services. Messages are published to a distributed messaging system for cross-instance communication.

In-memory implementation of LocalStateEventBus for testing and development. Uses Reactor Sinks for message broadcasting within the same JVM instance. Messages are not persisted and are lost when the application restarts.

State event bus that prioritizes local message delivery before distributed delivery. Messages are first sent to local subscribers within the same JVM instance, then forwarded to the distributed bus for cross-instance communication. This ensures low-latency local processing while maintaining consistency across instances.

Local state event bus that handles message routing within the same JVM instance. Messages are processed synchronously without network communication.

Filter that sends state events to the state event bus after command processing. This filter runs after domain events are sent, ensuring that subscribers receive both the domain event and the updated aggregate state.

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

Represents a state event that combines domain event stream data with aggregate state. State events are used in event sourcing to capture both the event and the resulting state.

Message bus for publishing and subscribing to state events. State events combine domain events with the resulting aggregate state, enabling subscribers to react to both the event and the current state.

Data class implementation of StateEvent that wraps a DomainEventStream with state information.

Exchange container for state events during message processing. Provides access to the state event message and allows attaching processing attributes.