RabbitMQ with nodejs

Question

nodejsプログラムからRabbitMQとの接続を確立しようとしています。しかし、接続を確立しておらず、どちらもエラーを投げていません。私のコードは以下の通りです。どんな提案もお願いします。

var amqp = require('amqp'); 
var connection = amqp.createConnection({url:"amqp://guest:guest@localhost:15672"}); 

connection.on('ready', function(){ 

    var q = connection.queue('jsonmsg', function(q) { 
     console.log('connected'); 
     q.bind("#"); 
     q.subscribe(function (message) { 
      console.log('on connection' + message); 
     }); 
    }); 
}); 

Answer 1

管理ポート15672に接続しているようです。 標準のAMQPポートは5672です。ただし、amqp://プロトコルを使用すると、このポートが自動的に設定されます。

ので、変更しよう：URLの

var connection = amqp.createConnection({url:"amqp://guest:guest@localhost"}); 

のRabbitMQのドキュメントはhereです。