Как получить существующие параметры очереди в Nodejs AMQP?

StackOverflow https://stackoverflow.com//questions/23064773

  •  26-12-2019
  •  | 
  •  

Вопрос

Я использую send.js с помощью amqplib:

var rabbitMQ = require('amqplib');

rabbitMQ.connect('amqp://localhost').then(function(connection) {
  connection.createConfirmChannel().then(function(channel){
    channel.assertQueue('testQ').then(function(queue){

      channel.sendToQueue('testQ', new Buffer('foobar'), {}, function(err, ok){
        console.log(err?'nacked':'acked');
        connection.close();
      });

    }, console.warn);
  }, console.warn);
}, console.warn);
.

и a aice.js с использованием AMQP:

var amqp = require('amqp');
var connection = amqp.createConnection({ host: 'localhost' });

// Wait for connection to become established.
connection.on('ready', function () {
  connection.queue('testQ', function (q) {
    q.bind('#');
    q.subscribe(console.log);
  });
});

connection.on('error', console.log);
.

Проблема в том, что параметры по умолчанию для очередей не совпадают.Я получаю неудачную ошибку 406 предварительного обеспечения при попытке прочитать с AMQP после отправки с AMQPLIB или при отправке с AMQPLIB после подписания с AMQP.Я был бы счастлив выравниваться с какой-либо конфигурацией, если это работает.

Это было полезно?

Решение

Использование amqplib на обоих концах решена проблема.

Лицензировано под: CC-BY-SA с атрибуция
Не связан с StackOverflow
scroll top