这是我的代码：-

      // 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;
    }

它正在成功验证连接并检查交换是否存在，但问题是回调正在重复并且无法停止它。 感谢您的帮助！谢谢：）