redisStateEventBus

@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