private RedisConnectionFactory redisConnectionFactory()

in src/main/java/com/epam/digital/data/platform/storage/message/factory/MessagePayloadStorageServiceFactory.java [109:121]


  private RedisConnectionFactory redisConnectionFactory(
      MessagePayloadRedisStorageConfiguration configuration) {
    var redisSentinelConfig = new RedisSentinelConfiguration();

    redisSentinelConfig.setMaster(configuration.getSentinel().getMaster());
    setSentinelNodes(redisSentinelConfig, configuration);
    redisSentinelConfig.setUsername(configuration.getUsername());
    redisSentinelConfig.setPassword(configuration.getPassword());

    var connectionFactory = new LettuceConnectionFactory(redisSentinelConfig);
    connectionFactory.afterPropertiesSet();
    return connectionFactory;
  }