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

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

Constructors

Link copied to clipboard
constructor()

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
@Bean
@ConditionalOnProperty(value = ["wow.command.bus.type"], havingValue = "redis")
@ConditionalOnMissingBean(value = [DistributedCommandBus::class])
fun redisCommandBus(redisTemplate: ReactiveStringRedisTemplate, recoveryProperties: RedisStreamRecoveryProperties, retentionProperties: RedisStreamRetentionProperties, observers: ObjectProvider<RedisMessageBusObserver>, @Qualifier(value = "redisTransportFailurePolicy") failurePolicy: TransportFailurePolicy): DistributedCommandBus
Link copied to clipboard
@Bean
@ConditionalOnProperty(value = ["wow.event.bus.type"], havingValue = "redis")
@ConditionalOnMissingBean(value = [DistributedDomainEventBus::class])
fun redisDomainEventBus(redisTemplate: ReactiveStringRedisTemplate, recoveryProperties: RedisStreamRecoveryProperties, retentionProperties: RedisStreamRetentionProperties, observers: ObjectProvider<RedisMessageBusObserver>, @Qualifier(value = "redisTransportFailurePolicy") failurePolicy: TransportFailurePolicy): DistributedDomainEventBus
Link copied to clipboard
@Bean
@ConditionalOnProperty(value = ["wow.eventsourcing.state.bus.type"], havingValue = "redis")
@ConditionalOnMissingBean(value = [DistributedStateEventBus::class])
fun redisStateEventBus(redisTemplate: ReactiveStringRedisTemplate, recoveryProperties: RedisStreamRecoveryProperties, retentionProperties: RedisStreamRetentionProperties, observers: ObjectProvider<RedisMessageBusObserver>, @Qualifier(value = "redisTransportFailurePolicy") failurePolicy: TransportFailurePolicy): DistributedStateEventBus
Link copied to clipboard
@Bean(value = ["redisTransportFailurePolicy"])
@ConditionalOnMissingBean(name = ["redisTransportFailurePolicy"])
fun redisTransportFailurePolicy(receiverProperties: RedisStreamReceiverProperties): TransportFailurePolicy
Generated by Dokka
© 2026 Copyright