@highoutput/amqp - npm Package Compare versions

Comparing version 0.4.9 to 0.4.10

build/lib/client.js

@@ -44,7 +44,12 @@ "use strict";
         logger_1.default.tag(['client', 'request']).verbose(body);
-        this.sender.send({
-            reply_to: (_a = this.receiver) === null || _a === void 0 ? void 0 : _a.source.address,
-            correlation_id: correlationId,
-            body,
-        });
+        try {
+            this.sender.send({
+                reply_to: (_a = this.receiver) === null || _a === void 0 ? void 0 : _a.source.address,
+                correlation_id: correlationId,
+                body,
+            });
+        }
+        catch (err) {
+            logger_1.default.tag('client').warn(err);
+        }
         if (this.options.noResponse) {
@@ -51,0 +56,0 @@ return null;

build/lib/publisher.js

@@ -31,5 +31,10 @@ "use strict";
         logger_1.default.tag(['publisher', 'request']).verbose(body);
-        this.sender.send({
-            body,
-        });
+        try {
+            this.sender.send({
+                body,
+            });
+        }
+        catch (err) {
+            logger_1.default.tag('publisher').warn(err);
+        }
     }
@@ -36,0 +41,0 @@ async start() {

build/lib/worker.js

@@ -64,6 +64,11 @@ "use strict";
             const sender = await this.getSender(message.reply_to);
-            sender.send({
-                correlation_id: message.correlation_id,
-                body: response,
-            });
+            try {
+                sender.send({
+                    correlation_id: message.correlation_id,
+                    body: response,
+                });
+            }
+            catch (err) {
+                logger_1.default.tag('worker').warn(err);
+            }
         }
@@ -70,0 +75,0 @@ }

package.json

 {
   "name": "@highoutput/amqp",
-  "version": "0.4.9",
+  "version": "0.4.10",
   "description": "A simplified abstraction of the AMQP 1.0 protocol",
@@ -44,3 +44,3 @@ "keywords": [
     "@highoutput/error": "^0.1.3",
-    "@highoutput/logger": "^0.2.1",
+    "@highoutput/logger": "^0.2.2",
     "ramda": "^0.27.0",
@@ -54,3 +54,3 @@ "rhea": "^1.0.18",
   },
-  "gitHead": "de315595bb78c0e4b0d701a4bba654d43f6cd55a"
+  "gitHead": "516b08e855801286b3cc23423005893cb01b0cc9"
 }

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

55055

increased by1.34%

Lines of code

700

increased by2.19%

Worsened metrics

Number of downloads

18

decreased by-5.26%

Dependency changes

• Updated@highoutput/logger@^0.2.2