RedisEventStreamExchange

data class RedisEventStreamExchange(val message: DomainEventStream, acknowledge: Mono<Void>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange

Constructors

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

open override fun acknowledge(): Mono<Void>