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);
});
});
});
嘿它现在工作正常。非常感谢:)现在可以连接到RabbitMQ。 –
接受答案,如果它帮助你..! – Alan