SimpleEventStreamExchange

constructor(message: DomainEventStream, attributes: MutableMap<String, Any> = ConcurrentHashMap())

Creates a new SimpleEventStreamExchange with the given message and attributes

Parameters

message

The domain event stream message

attributes

The mutable map of attributes (default: ConcurrentHashMap)