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

Package-level declarations

Types

@ConditionalOnProperty(value = ["wow.redis.enabled"], matchIfMissing = true, havingValue = "true")

annotation class ConditionalOnRedisEnabled

@AutoConfiguration(after = [WowAutoConfiguration::class, DataRedisReactiveAutoConfiguration::class])

@ConditionalOnClass(value = [RedisEventStore::class])

@EnableConfigurationProperties(value = [RedisProperties::class, EventStoreProperties::class, StorageRoutingProperties::class])

class RedisEventSourcingAutoConfiguration

RedisMessageBusAutoConfiguration

@AutoConfiguration(before = [CommandAutoConfiguration::class, EventAutoConfiguration::class, StateAutoConfiguration::class], after = [DataRedisReactiveAutoConfiguration::class])

@ConditionalOnClass(value = [RedisCommandBus::class])

@EnableConfigurationProperties(value = [RedisStreamRecoveryProperties::class, RedisStreamRetentionProperties::class, RedisStreamReceiverProperties::class])

class RedisMessageBusAutoConfiguration

RedisProperties

@ConfigurationProperties(prefix = "wow.redis")

class RedisProperties(var enabled: Boolean = true) : EnabledCapable

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-*).

RedisStreamRecoveryProperties

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

class RedisStreamRecoveryProperties(var enabled: Boolean = true, var minIdleTime: Duration = Duration.ofMinutes(5), var interval: Duration = Duration.ofSeconds(30), var batchSize: Long = 100)

RedisStreamRetentionProperties

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

class RedisStreamRetentionProperties(var maxLength: Long? = null, var maxAge: Duration? = null, var approximate: Boolean = true, var reapIdleConsumers: Boolean = true, var consumerIdleTimeout: Duration = RedisStreamRetentionOptions.DEFAULT_CONSUMER_IDLE_TIMEOUT)

What the Redis stream bus keeps (RedisStreamRetentionOptions). Trimming is off unless maxLength or maxAge is set; idle consumers with nothing pending are deleted unless reapIdleConsumers is false.

Properties

ENABLED_KEY

const val ENABLED_KEY: String