Как получить исключение, когда Amqp не может подключиться? - PullRequest
2 голосов
/ 30 октября 2019
const amqp = require('amqp-connection-manager')

const {CONNECTION_URL} = require('./config/env')

class AmqpConnectionService {

  async openConnection() {
    this.connection = await amqp.connect([CONNECTION_URL])
    this.channelWrapper = await this.connection.createChannel({setup(channel) {}})

    await this.channelWrapper.waitForConnect()
  }

С этим кодом, если CONNECTION_URL является неправильным URL, код застревает на waitForConnect().

...