wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.redis/RedisStreamReceiverProperties

RedisStreamReceiverProperties

@ConfigurationProperties(prefix = "wow.redis.message-bus.receiver")

class RedisStreamReceiverProperties(var retryAttempts: Long = TransportFailurePolicy.DEFAULT_RECEIVE_RETRY_ATTEMPTS, var retryBackoff: Duration = TransportFailurePolicy.DEFAULT_RECEIVE_RETRY_BACKOFF)

Receive-side policy of the Redis Streams buses: consecutive receive failures are retried retryAttempts times with an exponential backoff from retryBackoff (the same defaults as wow.kafka.receiver.retry-*).

Constructors

constructor(retryAttempts: Long = TransportFailurePolicy.DEFAULT_RECEIVE_RETRY_ATTEMPTS, retryBackoff: Duration = TransportFailurePolicy.DEFAULT_RECEIVE_RETRY_BACKOFF)

Types

Companion

object Companion

Properties

retryAttempts

var retryAttempts: Long

retryBackoff

var retryBackoff: Duration

Functions

toFailurePolicy

fun toFailurePolicy(): TransportFailurePolicy