bullmq - npm Package Compare versions

Comparing version 5.7.7 to 5.7.8

dist/cjs/classes/worker.js

@@ -306,2 +306,3 @@ "use strict";
         }
+        let timeout;
         try {
@@ -317,3 +318,3 @@ if (!this.closing) {
                     // don't get a response in the expected time.
-                    const timeout = setTimeout(async () => {
+                    timeout = setTimeout(async () => {
                         await this.blockingConnection.disconnect();
@@ -326,3 +327,2 @@ await this.blockingConnection.reconnect();
                     const result = await bclient.bzpopmin(this.keys.marker, blockTimeout);
-                    clearTimeout(timeout);
                     if (result) {
@@ -346,2 +346,5 @@ const [_key, member, score] = result;
         }
+        finally {
+            clearTimeout(timeout);
+        }
         return Infinity;
@@ -348,0 +351,0 @@ }

dist/esm/classes/worker.js

@@ -303,2 +303,3 @@ import * as fs from 'fs';
         }
+        let timeout;
         try {
@@ -314,3 +315,3 @@ if (!this.closing) {
                     // don't get a response in the expected time.
-                    const timeout = setTimeout(async () => {
+                    timeout = setTimeout(async () => {
                         await this.blockingConnection.disconnect();
@@ -323,3 +324,2 @@ await this.blockingConnection.reconnect();
                     const result = await bclient.bzpopmin(this.keys.marker, blockTimeout);
-                    clearTimeout(timeout);
                     if (result) {
@@ -343,2 +343,5 @@ const [_key, member, score] = result;
         }
+        finally {
+            clearTimeout(timeout);
+        }
         return Infinity;
@@ -345,0 +348,0 @@ }

package.json

 {
   "name": "bullmq",
-  "version": "5.7.7",
+  "version": "5.7.8",
   "description": "Queue for messages and jobs based on Redis",
@@ -5,0 +5,0 @@ "homepage": "https://bullmq.io/",

README.md

@@ -41,4 +41,12 @@ <div align="center">
 
+## 🌐 Language agnostic BullMQ
+
 Do you need to work with BullMQ on platforms other than Node.js? If so, check out the [BullMQ Proxy](https://github.com/taskforcesh/bullmq-proxy)
 
+## 🌟 Rediscover Scale Conference 2024
+
+Discover the latest in in-memory and real-time data technologies at **Rediscover Scale 2024**. Ideal for engineers, architects, and technical leaders looking to push technological boundaries. Connect with experts and advance your skills at The Foundry SF, San Francisco.
+
+[Learn more and register here!](https://www.rediscoverscale.com/)
+
 # Official FrontEnd
@@ -45,0 +53,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

1503067

increased by0.04%

Lines of code

24191

increased by0.02%

Number of lines in readme file

263

increased by3.14%

No dependency changes