diff --git a/src/queue.js b/src/queue.js index 7935e01..9f934b7 100644 --- a/src/queue.js +++ b/src/queue.js @@ -1,9 +1,11 @@ const { v4: uuid } = require('uuid') const Queue = require('bull') + +const { netId } = require('./config') const { status } = require('./constants') const { redis, redisUrl } = require('./modules/redis') -const queue = new Queue('proofs', redisUrl, { +const queue = new Queue(`proofs_${netId}`, redisUrl, { lockDuration: 300000, // Key expiration time for job locks. lockRenewTime: 30000, // Interval on which to acquire the job lock stalledInterval: 30000, // How often check for stalled jobs (use 0 for never checking).