@techloop/amqp-broker - npm Package Compare versions

Comparing version 1.4.3 to 1.4.4

lib/amqp.js

@@ -24,7 +24,4 @@ if (!process.env.RABBITMQ_DSN) {
     const exchange = connection.exchange(process.env.EXCHANGE_NAME)
-    exchange.on("ready", () => {
-      console.log('Exchange is ready');
-      callback(false, connection, exchange);
-    })
+    callback(false, connection, exchange)
   })
 }

lib/broker.js

@@ -31,3 +31,3 @@ if (!process.env.EXCHANGE_NAME) {
 
-  onQueueOpen(failed_q, q) {
+  onQueueOpen(q, failed_q) {
     console.log(`Queue ${q.name} was opened`);
@@ -44,3 +44,3 @@ this.set('q', q);
       console.log(bindTo);
-      q.bind(process.env.EXCHANGE_NAME, bindTo, onQueueBind(q.name, bindTo));
+      q.bind(this.exchange, bindTo, onQueueBind(q.name, bindTo));
     });
@@ -70,4 +70,4 @@ q.subscribe(parseIncomingMessage);
       const options = { autoDelete: false, durable: true };
-      connection.queue(process.env.QUEUE_NAME, options, (q) => { onQueueOpen(false, q) });
-      connection.queue(`${process.env.QUEUE_NAME}_failed`, options, (q) => { onQueueOpen(true, q) });
+      connection.queue(process.env.QUEUE_NAME, options, (q) => { onQueueOpen(q, false) });
+      connection.queue(`${process.env.QUEUE_NAME}_failed`, options, (q) => { onQueueOpen(q, true) });
     });
@@ -74,0 +74,0 @@ }

package.json

 {
   "name": "@techloop/amqp-broker",
-  "version": "1.4.3",
+  "version": "1.4.4",
   "description": "AMQP broker for microservices communication",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Number of low supply chain risk alerts

9

decreased by-10%

Worsened metrics

Total package byte prevSize

4685

decreased by-1.99%

Lines of code

133

decreased by-2.21%

No dependency changes