diff --git a/streaming/index.js b/streaming/index.js index 8d2cfc9b67b..cf477134dca 100644 --- a/streaming/index.js +++ b/streaming/index.js @@ -245,7 +245,7 @@ const redisConfigFromEnv = (env) => { let redisDatabase = parseIntFromEnv(env.REDIS_DB, 0, 'REDIS_DB'); /** @type {import('ioredis').RedisOptions} */ - const redisParams = { + let redisParams = { host: env.REDIS_HOST || '127.0.0.1', port: redisPort, db: redisDatabase, @@ -253,16 +253,16 @@ const redisConfigFromEnv = (env) => { }; if (env.REDIS_SENTINEL) { - redisParams = { - password: env.REDIS_PASSWORD || undefined, - sentinels: env.REDIS_SENTINEL.split(',').map(h => { - const s = h.split(':'); - const host = s[0] || '127.0.0.1'; - const port = s[1] || '26379'; - return { "host": host, "port": port }; - }), - name: env.REDIS_SENTINEL_MASTER || 'mymaster', - }; + redisParams = { + password: env.REDIS_PASSWORD || undefined, + sentinels: env.REDIS_SENTINEL.split(',').map(h => { + const s = h.split(':'); + const host = s[0] || '127.0.0.1'; + const port = s[1] || '26379'; + return { "host": host, "port": port }; + }), + name: env.REDIS_SENTINEL_MASTER || 'mymaster', + }; } // redisParams.path takes precedence over host and port.