From 5b63d2057043088effb19fe7504d6df3402acebb Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Fri, 13 Oct 2017 10:44:18 +0200
Subject: move failed jobs to failed queue

---
 worker.js | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index 936cf6e..571b69d 100644
--- a/worker.js
+++ b/worker.js
@@ -54,6 +54,10 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
             await getTelemetry(url, msg.properties.headers.match_api_id);
         } catch (err) {
             logger.error("Telemetry download error", err);
+            await ch.sendToQueue(QUEUE + "_failed", msg.content, {
+                persistent: true,
+                headers: msg.properties.headers
+            });
             ch.nack(msg, false, false);
             return;
         }
-- 
cgit v1.3.1