Вот мой код: -
// var passedcode = new Buffer.from(password, 'base64').toString('ascii');
var passedcode = "alpha123!"
let promise = new Promise((resolve, reject)=> {
var amqp_url = `amqp://${userName}:${passedcode}@${brokerhost}:${brokerport}/${vhostname}`;
var amqpConnectionDetails = {
'host':'myhost.com',
'port':5672,
'login':'admin',
'password':'vhost123!',
'vhost':'gmail.com'
};
var connection= amqp1.createConnection(amqpConnectionDetails);
return connection.on('ready',()=>{
connection.exchange(exchangeName, {'passive' :false }, error => {
if(error){
console.log("Exchagne not existsss");
throw error;
}
resolve(ok);
})
})
})
try {
promise.
then(() => {
return ({ 'result': 'Verified' });
})
return await promise;
}
catch (err) {
throw err;
}
}
catch (err) {
logger.info("Error encounterd while validating AMQP connection" + err)
throw err;
}
он успешно проверяет соединение и проверяет, существует ли обмен, но проблема в том, что обратный вызов получает повторение и не может чтобы остановить это. Ваша помощь приветствуется! Спасибо:)