diff --git a/packages/cli/src/config/schema.ts b/packages/cli/src/config/schema.ts index a0ca581d04a26..622f740aa7dce 100644 --- a/packages/cli/src/config/schema.ts +++ b/packages/cli/src/config/schema.ts @@ -399,6 +399,12 @@ export const schema = { default: '', env: 'QUEUE_BULL_REDIS_CLUSTER_NODES', }, + tls: { + format: 'Boolean', + default: false, + env: 'QUEUE_BULL_REDIS_TLS', + doc: 'Enable TLS on Redis connections. Default: false', + }, }, queueRecoveryInterval: { doc: 'If > 0 enables an active polling to the queue that can recover for Redis crashes. Given in seconds; 0 is disabled. May increase Redis traffic significantly.', diff --git a/packages/cli/src/services/redis/RedisServiceHelper.ts b/packages/cli/src/services/redis/RedisServiceHelper.ts index 7faab169bc3da..32b5d823cbd9f 100644 --- a/packages/cli/src/services/redis/RedisServiceHelper.ts +++ b/packages/cli/src/services/redis/RedisServiceHelper.ts @@ -55,6 +55,7 @@ export function getRedisStandardClient( enableReadyCheck: false, maxRetriesPerRequest: null, }; + if (config.getEnv('queue.bull.redis.tls')) sharedRedisOptions.tls = {}; LoggerProxy.debug( `Initialising Redis client${redisType ? ` of type ${redisType}` : ''} connection with host: ${ host ?? 'localhost' @@ -101,6 +102,7 @@ export function getRedisClusterClient( enableReadyCheck: false, maxRetriesPerRequest: null, }; + if (config.getEnv('queue.bull.redis.tls')) sharedRedisOptions.tls = {}; LoggerProxy.debug( `Initialising Redis cluster${ redisType ? ` of type ${redisType}` : ''