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])

class RedisMessageBusAutoConfiguration

Constructors

RedisMessageBusAutoConfiguration

constructor()

Functions

redisCommandBus

@Bean

@ConditionalOnProperty(value = ["wow.command.bus.type"], havingValue = "redis")

@ConditionalOnMissingBean(value = [DistributedCommandBus::class])

fun redisCommandBus(redisTemplate: ReactiveStringRedisTemplate, recoveryProperties: RedisStreamRecoveryProperties, observers: ObjectProvider<RedisMessageBusObserver>): DistributedCommandBus

redisDomainEventBus

@Bean

@ConditionalOnProperty(value = ["wow.event.bus.type"], havingValue = "redis")

@ConditionalOnMissingBean(value = [DistributedDomainEventBus::class])

fun redisDomainEventBus(redisTemplate: ReactiveStringRedisTemplate, recoveryProperties: RedisStreamRecoveryProperties, observers: ObjectProvider<RedisMessageBusObserver>): DistributedDomainEventBus

redisStateEventBus

@Bean

@ConditionalOnProperty(value = ["wow.eventsourcing.state.bus.type"], havingValue = "redis")

@ConditionalOnMissingBean(value = [DistributedStateEventBus::class])

fun redisStateEventBus(redisTemplate: ReactiveStringRedisTemplate, recoveryProperties: RedisStreamRecoveryProperties, observers: ObjectProvider<RedisMessageBusObserver>): DistributedStateEventBus