@cheep/transport-rabbitmq - npm Package Compare versions

Comparing version 1.1.1 to 1.1.2

package.json

 {
   "name": "@cheep/transport-rabbitmq",
-  "version": "1.1.1",
+  "version": "1.1.2",
   "contributors": [
@@ -25,3 +25,3 @@ "Ezeki",
     "amqplib": "0.7.1",
-    "@cheep/transport": "1.1.0"
+    "@cheep/transport": "1.3.0"
   },
@@ -28,0 +28,0 @@ "main": "src/index.js",

src/lib/rabbitmq.transport.d.ts

@@ -42,2 +42,4 @@ import { FailedMessage, SendMessageProps, SendReplyMessageProps, TransportBase, TransportOptions, TransportUtils } from '@cheep/transport';
     protected sendReplyMessage(props: SendReplyMessageProps): Promise<void>;
+    protected onRouteHandlerAdd(route: string): void;
+    protected onRouteHandlerRemove(route: string): void;
 }

src/lib/rabbitmq.transport.js

@@ -70,3 +70,5 @@ "use strict";
             const prefixes = this.getRegisteredPrefixes();
-            const patterns = prefixes.map(x => `${x}.#`).concat(routes);
+            const patterns = prefixes
+                .map(x => [x, `#`].filter(x => x).join('.'))
+                .concat(routes);
             this.bindingSetup = (x) => tslib_1.__awaiter(this, void 0, void 0, function* () {
@@ -182,3 +184,5 @@ yield Promise.all(patterns.map(pattern => x.bindQueue(this.queueName, this.options.publishExchangeName, pattern)));
                         }
-                        catch (err) { }
+                        catch (err) {
+                            /**/
+                        }
                     }
@@ -221,4 +225,14 @@ try {
     }
+    onRouteHandlerAdd(route) {
+        if (this.state !== transport_1.TransportState.STARTED) {
+            return;
+        }
+    }
+    onRouteHandlerRemove(route) {
+        if (this.state !== transport_1.TransportState.STARTED) {
+            return;
+        }
+    }
 }
 exports.RabbitMQTransport = RabbitMQTransport;
 //# sourceMappingURL=rabbitmq.transport.js.map

Fixed alerts

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

19044

increased by4.32%

Lines of code

283

increased by5.99%

Number of medium supply chain risk alerts

0

decreased by-100%

No dependency changes