RedisClientFactory

RedisClientFactory.java

public class RedisClientFactory implements DefaultValueFactory<RedissonClient> {
    @Override
    public RedissonClient create(PipelineOptions options) {
        RedisOptions redisOptions = options.as(RedisOptions.class);
        
        Config config = new Config();

        config.useSingleServer()
                .setAddress("redis://" + redisOptions.getRedisHost().get() + ":" + redisOptions.getRedisPort().get()");

        return Redisson.create(config);
    }

}