27 lines
678 B
TypeScript
27 lines
678 B
TypeScript
import process from 'process';
|
|
import { Queue, QueueScheduler } from 'bullmq';
|
|
import redisConfig from '../config/redis';
|
|
import logger from '../helpers/logger';
|
|
|
|
const CONNECTION_REFUSED = 'ECONNREFUSED';
|
|
|
|
const redisConnection = {
|
|
connection: redisConfig,
|
|
};
|
|
|
|
const flowQueue = new Queue('flow', redisConnection);
|
|
const queueScheduler = new QueueScheduler('flow', redisConnection);
|
|
|
|
process.on('SIGTERM', async () => {
|
|
await queueScheduler.close();
|
|
});
|
|
|
|
flowQueue.on('error', (err) => {
|
|
if ((err as any).code === CONNECTION_REFUSED) {
|
|
logger.error('Make sure you have installed Redis and it is running.', err);
|
|
process.exit();
|
|
}
|
|
});
|
|
|
|
export default flowQueue;
|