SimpleEventStreamExchange

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

Creates a new SimpleEventStreamExchange with the given message and attributes