wow-redis/me.ahoo.wow.redis.bus/RedisMessageBusObservation/PendingSweepStarted

PendingSweepStarted

data class PendingSweepStarted(val topic: String, val consumerGroup: String, val totalPendingMessages: Long, val minMessageId: String?, val maxMessageId: String?) : RedisMessageBusObservation

Constructors

PendingSweepStarted

constructor(topic: String, consumerGroup: String, totalPendingMessages: Long, minMessageId: String?, maxMessageId: String?)

Properties

open override val consumerGroup: String

val maxMessageId: String?

val minMessageId: String?

open override val topic: String

totalPendingMessages

val totalPendingMessages: Long