[FIX] Notification worker stopping on error (#20605)

RocketChat · Feb 11, 2021 · 592622c · 592622c
1 parent 7765759
commit 592622c
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/app/notification-queue/server/NotificationQueue.ts b/app/notification-queue/server/NotificationQueue.ts
@@ -41,7 +41,14 @@ class NotificationClass {
 			return;
 		}
 
-		setTimeout(this.worker.bind(this), this.cyclePause);
+		setTimeout(() => {
+			try {
+				this.worker.bind(this);
+			} catch (e) {
+				console.error('Error sending notification', e);
+				this.executeWorkerLater.bind(this);
+			}
+		}, this.cyclePause);
 	}
 
 	async worker(counter = 0): Promise<void> {