@cheep/transport-rabbitmq
Advanced tools
Comparing version 1.0.0-beta.17 to 1.0.0-beta.18
{ | ||
"name": "@cheep/transport-rabbitmq", | ||
"version": "1.0.0-beta.17", | ||
"version": "1.0.0-beta.18", | ||
"main": "src/index.js", | ||
@@ -8,4 +8,4 @@ "typings": "src/index.d.ts", | ||
"peerDependencies": { | ||
"@cheep/transport": "1.0.0-beta.17" | ||
"@cheep/transport": "1.0.0-beta.20" | ||
} | ||
} |
@@ -81,9 +81,11 @@ "use strict"; | ||
catch (err) { | ||
yield this.channel.sendToQueue(this.deadLetterQueueName, msg.content, { | ||
correlationId, | ||
replyTo, | ||
headers: { | ||
route, | ||
}, | ||
}); | ||
if (err instanceof transport_1.FailedMessageError) { | ||
yield this.channel.sendToQueue(this.deadLetterQueueName, Buffer.from(err.fullFailedMessage), { | ||
correlationId, | ||
replyTo, | ||
headers: { | ||
route, | ||
}, | ||
}); | ||
} | ||
} | ||
@@ -90,0 +92,0 @@ x.ack(msg); |
Sorry, the diff of this file is not supported yet
13058
190