0

我有一些代码,我想从我的 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 中运行时只有第一个(队列)参数出现的任何想法?我是流星菜鸟,所以也许是纤维问题?

4

1 回答 1

0

我决定在 Mongo 中跟踪状态变化比调试这个问题更容易。

于 2013-08-07T19:49:33.473 回答