From 7c78c7dacd397a35456fc76195fef5d1aadb5f12 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Wed, 26 Jul 2017 20:27:23 +0200
Subject: forward msg type to failed queue 2/2

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

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