Как получить существующие параметры очереди в Nodejs AMQP?
Вопрос
Я использую 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 на обоих концах решена проблема.
Не связан с StackOverflow