2013-10-28 4 views
8

Ich versuche, Verbindung mit RabbitMQ von Nodejs Programm herzustellen. Aber es stellt keine Verbindung her und wirft auch keinen Fehler. Mein Code ist wie folgt. Irgendwelche Vorschläge bitte.RabbitMQ mit 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); 
     }); 
    }); 
}); 

Antwort

16

Sieht aus wie Sie mit dem Management-Port 15672 verbinden. Der Standard-AMQP-Port ist 5672. Bei Verwendung des Protokolls amqp:// sollte dieser Port jedoch automatisch festgelegt werden.

Also, versuchen zu ändern: für url sind here

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

RabbitMQ docs.

+0

Hey, es funktioniert jetzt gut. Vielen Dank :) Ich kann jetzt mit RabbitMQ verbinden. –

+0

akzeptiere die Antwort, wenn es dir geholfen hat .. !! – Alan