RedisMessageBusObservation

Message payloads and Throwable instances are deliberately excluded so observers cannot retain sensitive payloads or failure object graphs.

Types

data class PendingClaimCompleted(val topic: String, val consumerGroup: String, val requestedMessages: Long, val claimedMessages: Long) : RedisMessageBusObservation

data class PendingClaimFailed(val topic: String, val consumerGroup: String, val requestedMessages: Long, val claimedMessages: Long, val failureType: String) : RedisMessageBusObservation

data class PendingScanFailed(val topic: String, val consumerGroup: String, val failureType: String) : RedisMessageBusObservation

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

data class RecordDecodeFailed(val topic: String, val consumerGroup: String, val recordId: String, val messageType: String, val reason: RedisRecordDecodeFailureReason, val failureType: String?) : RedisMessageBusObservation

abstract val topic: String