forward msg type to failed queue 2/2

1 files changed, 1 insertions, 0 deletions

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