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()
.