move failed jobs to failed queue

1 files changed, 4 insertions, 0 deletions

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;
         }