feat: immediately reconnect on amqplib connect timeout

jwalton · Aug 24, 2021 · ad06108 · ad06108
1 parent 69f1da3
commit ad06108
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/AmqpConnectionManager.js b/src/AmqpConnectionManager.js
@@ -208,8 +208,12 @@ export default class AmqpConnectionManager extends EventEmitter {
                 this._currentConnection = null;
                 this._connectPromise = null;
 
-                // TODO: Probably want to try right away here, especially if there are multiple brokers to try...
-                const handle = wait(this.reconnectTimeInSeconds * 1000);
+                let handle;
+                if (err.name === 'OperationalError' && err.message === 'connect ETIMEDOUT') {
+                    handle = wait(0);
+                } else {
+                    handle = wait(this.reconnectTimeInSeconds * 1000);
+                }
                 this._cancelRetriesHandler = handle.cancel;
 
                 return handle.promise().then(() => this._connect());