wow-redis/me.ahoo.wow.redis.bus/RedisStreamTransport/RedisTransportRecord

RedisTransportRecord

inner class RedisTransportRecord : TransportRecord

A received stream entry; acknowledging it sends XACK for its group.

Properties

val consumerName: String

val group: String

open override val id: String

open override val key: String?

open override val keyed: Boolean

open override val payload: String?

open override val topic: String

Functions

open override fun ack(): Mono<Void>