tornadocash/tornado-relayer
2
0
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

fix queue collision

Browse Source
This commit is contained in:
smart_ex 2022-04-19 17:08:41 +10:00 committed by Danil Kovtonyuk
parent ecdcb545fc
commit 38fd1e6a4c
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/queue.js
View File

@ -1,9 +1,11 @@
const { v4: uuid } = require('uuid') const { v4: uuid } = require('uuid')
const Queue = require('bull') const Queue = require('bull')
const { netId } = require('./config')
const { status } = require('./constants') const { status } = require('./constants')
const { redis, redisUrl } = require('./modules/redis') 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. lockDuration: 300000, // Key expiration time for job locks.
lockRenewTime: 30000, // Interval on which to acquire the job lock lockRenewTime: 30000, // Interval on which to acquire the job lock
stalledInterval: 30000, // How often check for stalled jobs (use 0 for never checking). stalledInterval: 30000, // How often check for stalled jobs (use 0 for never checking).