feat(queue): add option to skip wait until connection ready

src/classes/queue-base.ts

@@ -67,6 +67,7 @@ export class QueueBase extends EventEmitter implements MinimalQueue {
       shared: isRedisInstance(opts.connection),
       blocking: hasBlockingConnection,
       skipVersionCheck: opts.skipVersionCheck,
+      skipWaitingForReady: opts.skipWaitingForReady,
     });
 
     this.connection.on('error', (error: Error) => this.emit('error', error));

src/classes/redis-connection.ts

@@ -64,6 +64,7 @@ export class RedisConnection extends EventEmitter {
       shared?: boolean;
       blocking?: boolean;
       skipVersionCheck?: boolean;
+      skipWaitingForReady?: boolean;
     },
   ) {
     super();
@@ -73,6 +74,7 @@ export class RedisConnection extends EventEmitter {
       shared: false,
       blocking: true,
       skipVersionCheck: false,
+      skipWaitingForReady: false,
       ...extraOptions,
     };
 
@@ -241,7 +243,9 @@ export class RedisConnection extends EventEmitter {
 
     this._client.on('ready', this.handleClientReady);
 
-    await RedisConnection.waitUntilReady(this._client);
+    if (!this.extraOptions.skipWaitingForReady) {
+      await RedisConnection.waitUntilReady(this._client);
+    }
 
     this.loadCommands(this.packageVersion);
 

src/interfaces/queue-options.ts

@@ -38,6 +38,16 @@ export interface QueueBaseOptions {
    * Telemetry client
    */
   telemetry?: Telemetry;
+
+  /**
+   * Skip waiting for connection ready.
+   *
+   * In some instances if you want the queue to fail fast if the connection is
+   * not ready you can set this to true. This could be useful for testing and when
+   * adding jobs via HTTP endpoints for example.
+   *
+   */
+  skipWaitingForReady?: boolean;
 }
 
 /**
@@ -75,11 +85,6 @@ export interface QueueOptions extends QueueBaseOptions {
    * Advanced options for the repeatable jobs.
    */
   settings?: AdvancedRepeatOptions;
-
-  /**
-   * Telemetry client
-   */
-  telemetry?: Telemetry;
 }
 
 /**