summaryrefslogtreecommitdiff
path: root/worker.js
diff options
context:
space:
mode:
Diffstat (limited to 'worker.js')
-rw-r--r--worker.js1
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 {