これは私のコードです:
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 を使用しています。
byは見えますが、 textexchange
byrabbitmqctl list_exchanges
がありません。何が問題なのですか?testqueue
rabbitmqctl list_queues