在不同的队列中的消息并行消费+的RabbitMQ +的NodeJS

Question

看起来这是有写作的NodeJS应用在RabbitMQ的唯一库是

https://github.com/postwait/node-amqp

我有的发布消息发送到多个队列生产者以非常快的速度，并在消费者我创建每个队列的订阅。

connection.on('ready', function() { 
    for(var i=0;i<queues.length;i++) 
    connection.queue(queues[i],{autoDelete:false}, qOnReady); 
}); 
function qOnReady(q){ 
// Catch all messages 
    logger("Q "+q.name+" is ready"); 
    q.bind('#'); 
// Receive messages 
    q.subscribe(subscriber); 
} 

但是当我运行的所有消费者所消耗的消息是从一个特定的队列，直到队列被耗尽，订阅不会对其他queue.How做我实现启动消费并行消息。

Answer 1

您可能希望使用异步库来实现队列的并行执行。

虽然不知道它是否符合您的需求。

https://github.com/caolan/async#paralleltasks-callback