@techloop/amqp-broker
Advanced tools
Comparing version 1.3.3 to 1.3.4
@@ -31,4 +31,4 @@ if (!process.env.EXCHANGE_NAME) { | ||
onQueueOpen(failed_q,q){ | ||
console.log(failed_q,q); | ||
onQueueOpen(failed_q, q) { | ||
console.log(failed_q, q); | ||
console.log(`Queue ${q.name} was opened`); | ||
@@ -70,4 +70,4 @@ this.set("q", q); | ||
const options = { autoDelete: false, durable: true }; | ||
connection.queue(process.env.QUEUE_NAME, options, onQueueOpen(false)); | ||
connection.queue(`${process.env.QUEUE_NAME}_failed`, options, onQueueOpen(true)); | ||
connection.queue(process.env.QUEUE_NAME, options, (q) => { onQueueOpen(false, q) }); | ||
connection.queue(`${process.env.QUEUE_NAME}_failed`, options, (q) => { onQueueOpen(true, q) }); | ||
}); | ||
@@ -74,0 +74,0 @@ } |
{ | ||
"name": "@techloop/amqp-broker", | ||
"version": "1.3.3", | ||
"version": "1.3.4", | ||
"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
4525