@appolo/bus - npm Package Compare versions

Comparing version 8.0.11 to 8.0.12

module/src/topology/topologyManager.js

@@ -110,5 +110,6 @@ "use strict";
                 queue: handler.queue,
-                keys: [handler.eventName]
+                keys: [handler.routingKey || handler.eventName]
             });
         });
+        bindings = utils_1.Arrays.uniqBy(bindings, handler => handler.exchange + handler.queue + handler.keys.join());
         return bindings;
@@ -115,0 +116,0 @@ }

module/src/topology/topologyManager.ts

@@ -18,3 +18,3 @@ import {define, inject, singleton, Util, Define} from "@appolo/inject";
 import {HandlerSymbol, ReplySymbol, RequestSymbol} from "../common/decorators";
-import {Reflector, Strings} from "@appolo/utils";
+import {Reflector, Strings, Arrays} from "@appolo/utils";
 
@@ -179,6 +179,8 @@ @define()
                 queue: handler.queue,
-                keys: [handler.eventName]
+                keys: [handler.routingKey || handler.eventName]
             })
         });
 
+        bindings = Arrays.uniqBy(bindings, handler => handler.exchange + handler.queue + handler.keys.join());
+
         return bindings;
@@ -185,0 +187,0 @@ }

package.json

 {
   "name": "@appolo/bus",
-  "version": "8.0.11",
+  "version": "8.0.12",
   "description": "appolo bus module",
@@ -5,0 +5,0 @@ "publishConfig": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

82521

increased by0.34%

Lines of code

1841

increased by0.11%

No dependency changes