forward msg type to failed queue

1 files changed, 1 insertions, 0 deletions

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 {