From 632dce129dc6aea3d425b3391b3e485f8b07934e Mon Sep 17 00:00:00 2001
From: smart_ex <sergei.smart@gmail.com>
Date: Tue, 19 Apr 2022 17:09:45 +1000
Subject: [PATCH] fix queue collision

---
 src/queue.js | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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).