Как убедиться, что обмен уже существует в Vhost в AMQP в NodeJS? - PullRequest
0 голосов
/ 11 марта 2020

Вот мой код: -

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

он успешно проверяет соединение и проверяет, существует ли обмен, но проблема в том, что обратный вызов получает повторение и не может чтобы остановить это. Ваша помощь приветствуется! Спасибо:)

...