tornadocash/tornado-relayer
1
0
Fork 0
mirror of https://github.com/tornadocash/tornado-relayer synced 2024-02-02 15:04:06 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix queue collision

Browse Source
This commit is contained in:
smart_ex 2022-04-19 17:09:45 +10:00
parent 0eca15e788
commit 8110ba6f04
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/queue.js
View File

@ -1,11 +1,11 @@
const { v4: uuid } = require('uuid') const { v4: uuid } = require('uuid')
const Queue = require('bull') const Queue = require('bull')
const Redis = require('ioredis') const Redis = require('ioredis')
const { redisUrl } = require('./config') const { redisUrl, netId } = require('./config')
const { status } = require('./constants') const { status } = require('./constants')
const redis = new Redis(redisUrl) const redis = new Redis(redisUrl)
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).