Skip to content

Commit

Permalink
fix(core): Add support for in-transit encryption (TLS) on Redis conne…
Browse files Browse the repository at this point in the history
…ctions
  • Loading branch information
netroy committed Aug 30, 2023
1 parent dfe0fa6 commit c879d2c
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 0 deletions.
6 changes: 6 additions & 0 deletions packages/cli/src/config/schema.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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.',
Expand Down
2 changes: 2 additions & 0 deletions packages/cli/src/services/redis/RedisServiceHelper.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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'
Expand Down Expand Up @@ -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}` : ''
Expand Down

0 comments on commit c879d2c

Please sign in to comment.