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

redisCommandBus

@Bean

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

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

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