@techloop/amqp-broker
Advanced tools
Comparing version 1.4.0 to 1.4.1
@@ -105,21 +105,6 @@ if (!process.env.EXCHANGE_NAME) { | ||
msg: data, | ||
key: deliveryInfo.routingKey | ||
key: deliveryInfo.routingKey, | ||
connection, | ||
exchange | ||
}) | ||
.then(() => { | ||
console.log(`Task ${Task.key} accomplished`) | ||
}) | ||
.catch(error => { | ||
console.error(`Error: failed to run callback for task key=${Task.key}`, error); | ||
if (Task.handleFailedMessages) { | ||
const failureRoutingKey = `failed.${Task.key}`; | ||
this.exchange.publish(failureRoutingKey, data, { | ||
mandatory: true | ||
}, | ||
(err, msg) => { | ||
console.error('Can not publish message', err, msg) | ||
}); | ||
} | ||
}); | ||
} | ||
@@ -126,0 +111,0 @@ } |
{ | ||
"name": "@techloop/amqp-broker", | ||
"version": "1.4.0", | ||
"version": "1.4.1", | ||
"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
6
4682
132