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이다.