@techloop/amqp-broker
Advanced tools
Comparing version 1.5.6 to 1.5.7
@@ -84,3 +84,4 @@ if (!process.env.EXCHANGE_NAME) { | ||
parseIncomingMessage(message, headers, deliveryInfo, messageObject) { | ||
console.log('Received new AMQP message: ', message, ' deliveryInfo: ', deliveryInfo, ' headers:', headers) | ||
let data = new Buffer(message.data).toString(); | ||
console.log('Received new AMQP message: ', data, ' deliveryInfo: ', deliveryInfo, ' headers:', headers) | ||
@@ -91,3 +92,2 @@ if (!deliveryInfo.routingKey) { | ||
} | ||
let data = new Buffer(message.data).toString(); | ||
if (data) { | ||
@@ -94,0 +94,0 @@ try { |
{ | ||
"name": "@techloop/amqp-broker", | ||
"version": "1.5.6", | ||
"version": "1.5.7", | ||
"description": "AMQP broker for microservices communication", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
20655