Come ottenere i parametri della coda esistenti in nodejs amqp?

Question

Sto usando un send.js usando 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);

.

e una ricezione.js usando 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);

.

Il problema è che le opzioni predefinite per le code non corrispondono.Ottengo un errore di 406 precondition fallito durante il tentativo di leggere con AmQP dopo l'invio con AmQplib o durante l'invio con AmQplib dopo essere stato sottoscritto con AMQP.Sarei felice allinearsi su entrambe le configurazioni, purché funzioni.

Answer 1

L'uso di amqplib su entrambe le estremità ha risolto il problema.