forked from ServiceCanada/cens
-
Notifications
You must be signed in to change notification settings - Fork 0
/
notifyQueue.js
38 lines (32 loc) · 1.02 KB
/
notifyQueue.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
const Queue = require('bull');
const { setQueues } = require('bull-board');
const { UI } = require('bull-board');
const redisUri = process.env.REDIS_URI || 'x-notify-redis';
const redisPort = process.env.REDIS_PORT || '6379';
const redisSentinel1Uri = process.env.REDIS_SENTINEL_1_URI || '127.0.0.1';
const redisSentinel1Port = process.env.REDIS_SENTINEL_1_PORT || '26379';
const redisSentinel2Uri = process.env.REDIS_SENTINEL_2_URI || '127.0.0.1';
const redisSentinel2Port = process.env.REDIS_SENTINEL_2_PORT || '26379';
const redisMasterName = process.env.REDIS_MASTER_NAME || 'x-notify-master';
let redisConf = {};
if (process.env.NODE_ENV === 'prod') {
redisConf = {
redis: {
sentinels: [
{ host: redisSentinel1Uri, port: redisSentinel1Port },
{ host: redisSentinel2Uri, port: redisSentinel2Port }
],
name: redisMasterName,
}
}
} else {
redisConf = {
redis: {
host: redisUri,
port: redisPort,
}
}
}
const notifyQueue = new Queue('sendMail', redisConf);
setQueues([notifyQueue]);
module.exports.UI = UI;