fix: add retry and error handling settings to queues

NFTX-project · Feb 1, 2024 · 03fe4d0 · 03fe4d0
1 parent 9302c11
commit 03fe4d0
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 3 deletions.
diff --git a/packages/queue/src/listeners/onNetworkSignal.ts b/packages/queue/src/listeners/onNetworkSignal.ts
@@ -12,7 +12,7 @@ const onNetworkSignal = (network: number, callback: SignalCallback) => {
 
   return createWorker(queueName, (job) => {
     const { name, data } = job;
-    callback({ payload: data, type: name as any });
+    return callback({ payload: data, type: name as any });
   });
 };
 

diff --git a/packages/queue/src/listeners/onSignal.ts b/packages/queue/src/listeners/onSignal.ts
@@ -8,7 +8,7 @@ import { SignalCallback } from '../types';
 const onSignal = (callback: SignalCallback) => {
   return createWorker(SIGNAL_QUEUE_NAME, (job) => {
     const { name, data } = job;
-    callback({ type: name as any, payload: data });
+    return callback({ type: name as any, payload: data });
   });
 };
 

diff --git a/packages/queue/src/queues/getQueue.ts b/packages/queue/src/queues/getQueue.ts
@@ -23,7 +23,18 @@ export class NftxQueue extends Queue {
 const getQueue = (queueName: string) => {
   return (
     NftxQueue.queues[queueName] ||
-    new NftxQueue(queueName, { connection: getConnection(queueName) })
+    new NftxQueue(queueName, {
+      connection: getConnection(queueName),
+      defaultJobOptions: {
+        attempts: 5,
+        removeOnComplete: true,
+        removeOnFail: true,
+        backoff: {
+          type: 'exponential',
+          delay: 30000,
+        },
+      },
+    })
   );
 };