fix(worker): remove blockingConnection option (#2922)

src/classes/queue-events-producer.ts

@@ -16,7 +16,6 @@ export class QueueEventsProducer extends QueueBase {
     super(
       name,
       {
-        blockingConnection: false,
         ...opts,
       },
       Connection,

src/classes/worker.ts

@@ -207,7 +207,6 @@ export class Worker<
       name,
       {
         ...opts,
-        blockingConnection: true,
       },
       Connection,
     );
@@ -963,7 +962,7 @@ will never work with more accuracy than 1ms. */
    * This method waits for current jobs to finalize before returning.
    *
    * @param force - Use force boolean parameter if you do not want to wait for
-   * current jobs to be processed. When using telemetry, be mindful that it can 
+   * current jobs to be processed. When using telemetry, be mindful that it can
    * interfere with the proper closure of spans, potentially preventing them from being exported.
    *
    * @returns Promise that resolves when the worker has been closed.

src/interfaces/queue-options.ts

@@ -17,12 +17,6 @@ export interface QueueBaseOptions {
    */
   connection: ConnectionOptions;
 
-  /**
-   * Denotes commands should retry indefinitely.
-   * @deprecated
-   */
-  blockingConnection?: boolean;
-
   /**
    * Prefix for all queue keys.
    */

tests/test_worker.ts

@@ -479,7 +479,7 @@ describe('workers', function () {
     // Add spy to worker.moveToActive
     const spy = sinon.spy(worker, 'moveToActive');
     const bclientSpy = sinon.spy(
-      await worker.blockingConnection.client,
+      await (worker as any).blockingConnection.client,
       'bzpopmin',
     );
 
@@ -521,7 +521,7 @@ describe('workers', function () {
     // Add spy to worker.moveToActive
     const spy = sinon.spy(worker, 'moveToActive');
     const bclientSpy = sinon.spy(
-      await worker.blockingConnection.client,
+      await (worker as any).blockingConnection.client,
       'bzpopmin',
     );