我有一些代码,我想从我的 Meteor 应用程序中获取 RabbitMQ 的当前消息计数。在 Node 控制台中运行代码正确地给出了回调参数,但在 Meteor 中相同的代码只给出了第一个参数。
rabbitMQ = AMQP.createConnection({ host: '127.0.0.1' });
rabbitMQ.addListener('ready', function(){
console.log('Connecting to the channel...');
});
rabbitMQ.addListener('ready', function(){
rabbitMQ.queue('foo', {durable:true, autoDelete:false}, function (queue, messages, consumers) {
console.log('Queue ' + queue.name + ' is open with ' + messages + ' messages');
});
});
在节点打印中:
Connecting to the channel...
Queue foo is open with 3 messages
在流星打印中:
Connecting to the channel...
Queue foo is open with undefined messages
关于为什么在 Meteor 中运行时只有第一个(队列)参数出现的任何想法?我是流星菜鸟,所以也许是纤维问题?