@techloop/amqp-broker
Advanced tools
Comparing version 1.5.5 to 1.5.6
@@ -84,2 +84,4 @@ if (!process.env.EXCHANGE_NAME) { | ||
parseIncomingMessage(message, headers, deliveryInfo, messageObject) { | ||
console.log('Received new AMQP message: ', message, ' deliveryInfo: ', deliveryInfo, ' headers:', headers) | ||
if (!deliveryInfo.routingKey) { | ||
@@ -86,0 +88,0 @@ console.error("Received message without routing key, discarding"); |
{ | ||
"name": "@techloop/amqp-broker", | ||
"version": "1.5.5", | ||
"version": "1.5.6", | ||
"description": "AMQP broker for microservices communication", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
20658
144