imq - npm Package Compare versions

Comparing version 1.2.11 to 1.2.12

package.json

 {
   "name": "imq",
-  "version": "1.2.11",
+  "version": "1.2.12",
   "description": "Simple JSON-based messaging queue for inter service communication",
@@ -5,0 +5,0 @@ "scripts": {

src/ClusteredRedisQueue.d.ts

@@ -7,5 +7,5 @@ /// <reference types="node" />
     private imqs;
-    private options;
-    private mqOptions;
-    private servers;
+    private readonly options;
+    private readonly mqOptions;
+    private readonly servers;
     private currentQueue;
@@ -12,0 +12,0 @@ private queueLength;

src/ClusteredRedisQueue.js

@@ -34,2 +34,3 @@ "use strict";
         this.currentQueue = 0;
+        // noinspection TypescriptExplicitMemberType,TypeScriptFieldCanBeMadeReadonly
         this.queueLength = 0;
@@ -36,0 +37,0 @@ this.options = Object.assign({}, _1.DEFAULT_IMQ_OPTIONS, options || {});

src/redis.js

@@ -23,6 +23,2 @@ "use strict";
 const _1 = require(".");
-process.on('unhandledRejection', (reason, p) => {
-    console.log('Unhandled Rejection at: Promise', p, 'reason:', reason);
-    // application specific logging, throwing an error, or other logic here
-});
 const commands = [...new Set(require('redis-commands').list.map((name) => name.toLowerCase()))].filter((name) => name !== 'stream');
@@ -29,0 +25,0 @@ /**

src/RedisQueue.d.ts

@@ -51,3 +51,3 @@ /// <reference types="node" />
     private safeCheckInterval;
-    private redisKey;
+    private readonly redisKey;
     /**
@@ -80,4 +80,4 @@ * @type {IRedisClient}
     private readonly key;
-    private pack;
-    private unpack;
+    private readonly pack;
+    private readonly unpack;
     options: IMQOptions;
@@ -84,0 +84,0 @@ /**

src/RedisQueue.js

@@ -136,2 +136,3 @@ "use strict";
     }
+    // noinspection JSUnusedLocalSymbols
     set writer(conn) {
@@ -146,2 +147,3 @@ RedisQueue.writers[this.redisKey] = conn;
     }
+    // noinspection JSUnusedLocalSymbols
     set watcher(conn) {
@@ -360,8 +362,9 @@ this.watchers[this.redisKey] = conn;
                     catch (err) {
+                        // istanbul ignore next
                         if (err.message.match(/Stream connection ended/)) {
                             break;
                         }
-                        else {
-                            throw err;
-                        }
+                        // istanbul ignore next
+                        // noinspection ExceptionCaughtLocallyJS
+                        throw err;
                     }
@@ -396,2 +399,3 @@ }
                     catch (err) {
+                        // istanbul ignore next
                         break;
@@ -398,0 +402,0 @@ }

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

73779

increased by0.23%

Lines of code

2010

increased by0.05%

No dependency changes