From da57e1b71cb55d968c3f10b81a1ff73fc51b805c Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 25 Jul 2017 20:04:15 +0200
Subject: forward msg type to failed queue

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

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index 733b33a..2feeba6 100644
--- a/worker.js
+++ b/worker.js
@@ -186,6 +186,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
                     await ch.nack(msg, false, false);
                     await ch.sendToQueue(QUEUE + "_failed", msg.content, {
                         persistent: true,
+                        type: msg.properties.type,
                         headers: msg.properties.headers
                     });
                 } else {
-- 
cgit v1.3.1