2013-10-28 15 views
8

Sto tentando di stabilire una connessione con RabbitMQ dal programma nodejs. Ma non stabilisce una connessione, né lancia un errore. Il mio codice è il seguente Qualsiasi suggerimento per favore.RabbitMQ con 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); 
     }); 
    }); 
}); 

risposta

16

Sembra che ci si connette alla porta di gestione 15672. La porta AMQP standard è 5672. Tuttavia, l'utilizzo del protocollo amqp:// dovrebbe impostare automaticamente questa porta.

Quindi, cercare di cambiare:

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

docs RabbitMQ per url sono here.

+0

Hey adesso funziona bene. Grazie mille :) Sono in grado di connettermi a RabbitMQ ora. –

+0

accetta la risposta se ti ha aiutato .. !! – Alan