wow-redis/me.ahoo.wow.redis.bus/RedisStateEventExchange

RedisStateEventExchange

class RedisStateEventExchange<C : Any>(val message: StateEvent<C>, acknowledge: Mono<Void>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<C>

Constructors

RedisStateEventExchange

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

Properties

open override val attributes: MutableMap<String, Any>

open override val message: StateEvent<C>

Functions

open override fun acknowledge(): Mono<Void>