SimpleEventStreamExchange
class SimpleEventStreamExchange(val message: DomainEventStream, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange
Simple implementation of EventStreamExchange.
This class provides a basic implementation of the EventStreamExchange interface, storing the domain event stream message and managing exchange attributes.