resolve-bus-rabbitmq - npm Package Compare versions

Comparing version 0.19.0 to 0.19.1

es/on-message.js

@@ -14,3 +14,3 @@ const onMessage = async (pool, message) => {
       const topicHandlers = pool.handlers.get(topic);
-      if (topicHandlers == null) return;
+      if (topicHandlers == null) continue;
 
@@ -17,0 +17,0 @@ for (const handler of Array.from(topicHandlers)) {

lib/on-message.js

@@ -21,3 +21,3 @@ "use strict";
       const topicHandlers = pool.handlers.get(topic);
-      if (topicHandlers == null) return;
+      if (topicHandlers == null) continue;
 
@@ -24,0 +24,0 @@ for (const handler of Array.from(topicHandlers)) {

package.json

 {
   "name": "resolve-bus-rabbitmq",
-  "version": "0.19.0",
+  "version": "0.19.1",
   "description": "This package is an adapter for resolve-bus to emit events using RabbitMQ.",
@@ -30,3 +30,3 @@ "engines": {
     "amqplib": "^0.5.2",
-    "resolve-bus-base": "0.19.0"
+    "resolve-bus-base": "0.19.1"
   },
@@ -33,0 +33,0 @@ "devDependencies": {

No alert changes

Improved metrics

Total package byte prevSize

29316

increased by0.03%

Dependency changes

• + Addedresolve-bus-base@0.19.1(transitive)

• - Removedresolve-bus-base@0.19.0(transitive)

• Updatedresolve-bus-base@0.19.1