fix(queue): support REDIS_URL for deployment
This commit is contained in:
@@ -7,11 +7,15 @@ import { Queue, Worker, QueueOptions } from 'bullmq';
|
|||||||
import IORedis from 'ioredis';
|
import IORedis from 'ioredis';
|
||||||
|
|
||||||
// Redis connection
|
// Redis connection
|
||||||
const connection = new IORedis({
|
const connection = process.env.REDIS_URL
|
||||||
host: process.env.REDIS_HOST || 'localhost',
|
? new IORedis(process.env.REDIS_URL, {
|
||||||
port: parseInt(process.env.REDIS_PORT || '6379'),
|
maxRetriesPerRequest: null,
|
||||||
maxRetriesPerRequest: null,
|
})
|
||||||
});
|
: new IORedis({
|
||||||
|
host: process.env.REDIS_HOST || 'localhost',
|
||||||
|
port: parseInt(process.env.REDIS_PORT || '6379'),
|
||||||
|
maxRetriesPerRequest: null,
|
||||||
|
});
|
||||||
|
|
||||||
// Queue options
|
// Queue options
|
||||||
const queueOptions: QueueOptions = {
|
const queueOptions: QueueOptions = {
|
||||||
|
|||||||
Reference in New Issue
Block a user