diff --git a/src/QueueConnection.js b/src/QueueConnection.js index cb153ba..91b0193 100644 --- a/src/QueueConnection.js +++ b/src/QueueConnection.js @@ -101,16 +101,10 @@ class QueueConnection extends EventEmitter { configUrl = urls } - // handle multiple connection urls - if (Array.isArray(configUrl)) { - return this._connectWithMultipleUrls(configUrl, options) + if (!Array.isArray(configUrl)) { + configUrl = [configUrl] } - - // assume simple url string or standard url object - const connectionUrl = QueueConfig.urlStringToObject(configUrl) - const connection = await amqp.connect(configUrl, options) - this._activeConnectionConfig = connectionUrl - return connection + return this._connectWithMultipleUrls(configUrl, options) } async _connectWithMultipleUrls (urls, options) {