redisCommandBus

@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