无法使用节点中的exchange发送消息-amqp

Question

这是我的代码：

var amqp = require('amqp');

var connection = amqp.createConnection( { host: 'localhost' },  { defaultExchangeName: 'testexchange' });
connection.on('ready', function () {
  console.log('Connected to rabbitmq');
  var exchange = connection.exchange('testexchange', {confirm:true}, function(exch){
    console.log('Created exchange: ' + exch.name);
    var queue = connection.queue('testqueue', { durable: true }, function(q) {
      exch.publish('testqueue', {a:1}, {}, function(error) {
        console.log(error); 
      });
    });
  });
});

我使用的是node 0.10.2和node-amqp 0.1.6，

我可以看到rabbitmqctl list_exchanges的textexchange，但是没有rabbitmqctl list_queues的testqueue，有什么问题吗？

Answer 1

你必须先定义它。

connection.queue('testqueue', { durable: true })