2013-10-28 35 views
8

我試圖從nodejs程序與RabbitMQ建立連接。但它沒有建立連接,也沒有發生錯誤。我的代碼如下。任何建議請。RabbitMQ with nodejs

var amqp = require('amqp'); 
var connection = amqp.createConnection({url:"amqp://guest:[email protected]: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); 
     }); 
    }); 
}); 

回答

16

看起來像是連接到管理端口15672。 標準AMQP端口是5672。但是,使用amqp://協議應自動設置此端口。

因此,嘗試改變:

var connection = amqp.createConnection({url:"amqp://guest:[email protected]"}); 

的URL RabbitMQ的文檔是here

+0

嘿它現在工作正常。非常感謝:)現在可以連接到RabbitMQ。 –

+0

接受答案,如果它幫助你..! – Alan