amqp-cacoon - npm Package Compare versions

Comparing version 1.0.0 to 1.0.1

build/index.js

@@ -167,3 +167,3 @@ "use strict";
                         if (this.logger)
-                            this.logger.error('AMQPCacoon.connect: Error: ', e_2);
+                            this.logger.error('AMQPCacoon.getConsumerChannel: Error: ', e_2);
                         throw e_2;
@@ -218,4 +218,4 @@ case 5:
                         if (this.logger)
-                            this.logger.error('AMQPCacoon.connect: Error: ', e_3);
-                        return [3 /*break*/, 4];
+                            this.logger.error('AMQPCacoon.registerConsumer: Error: ', e_3);
+                        throw e_3;
                     case 4: return [2 /*return*/];
@@ -238,10 +238,12 @@ }
         return __awaiter(this, void 0, void 0, function () {
-            var channel, channelReady;
+            var channel_2, channelReady, e_4;
             var _this = this;
             return __generator(this, function (_a) {
                 switch (_a.label) {
-                    case 0: return [4 /*yield*/, this.getPublishChannel()];
+                    case 0:
+                        _a.trys.push([0, 5, , 6]);
+                        return [4 /*yield*/, this.getPublishChannel()];
                     case 1:
-                        channel = _a.sent();
-                        channelReady = channel.publish(exchange, routingKey, msgBuffer, options);
+                        channel_2 = _a.sent();
+                        channelReady = channel_2.publish(exchange, routingKey, msgBuffer, options);
                         if (this.logger) {
@@ -264,3 +266,3 @@ this.logger.trace("AMQPCacoon.publish result: " + channelReady);
                                 // TODO add timeout in case drain does not occur after x amount of time. Make timeout configurable
-                                channel.once('drain', function () {
+                                channel_2.once('drain', function () {
                                     if (_this.logger) {
@@ -277,3 +279,9 @@ _this.logger.trace('AMQPCacoon.publish "drain" received.');
                         _a.label = 4;
-                    case 4: return [2 /*return*/];
+                    case 4: return [3 /*break*/, 6];
+                    case 5:
+                        e_4 = _a.sent();
+                        if (this.logger)
+                            this.logger.error('AMQPCacoon.publish: Error: ', e_4);
+                        throw e_4;
+                    case 6: return [2 /*return*/];
                 }
@@ -280,0 +288,0 @@ });

package.json

 {
   "name": "amqp-cacoon",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "description": "AmqpCacoon is an abstraction around amqplib that provides a simple interface with flow control included out of the box",
@@ -29,14 +29,14 @@ "main": "build/index.js",
     "@types/chai": "^4.2.7",
+    "@types/lodash": "^4.14.149",
     "@types/mocha": "^5.2.7",
     "@types/node": "^13.1.6",
-    "@types/lodash": "^4.14.149",
-    "nodemon": "^2.0.2",
+    "chai": "^4.2.0",
+    "mocha": "^7.1.1",
+    "nodemon": "^2.0.3",
     "rimraf": "^3.0.0",
+    "sinon": "^8.1.0",
+    "ts-mock-imports": "^1.2.6",
     "ts-node": "^8.5.4",
     "ts-sinon": "^1.0.24",
-    "typescript": "^3.7.4",
-    "chai": "^4.2.0",
-    "mocha": "^7.0.0",
-    "sinon": "^8.1.0",
-    "ts-mock-imports": "^1.2.6"
+    "typescript": "^3.7.4"
   },
@@ -43,0 +43,0 @@ "publishConfig": {

No alert changes

Improved metrics

Total package byte prevSize

27176

increased by1.9%

Lines of code

443

increased by1.84%

No dependency changes