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

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

diff --git a/src/queue.js b/src/queue.js
index dbd2ad4..dfcf799 100644
--- a/src/queue.js
+++ b/src/queue.js
@@ -1,11 +1,11 @@
 const { v4: uuid } = require('uuid')
 const Queue = require('bull')
 const Redis = require('ioredis')
-const { redisUrl } = require('./config')
+const { redisUrl, netId } = require('./config')
 const { status } = require('./constants')
 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.
   lockRenewTime: 30000, // Interval on which to acquire the job lock
   stalledInterval: 30000, // How often check for stalled jobs (use 0 for never checking).