RedisEventStreamExchange

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