使用单个应用程序监视多个RabbitMq订阅

Question

我有一个我在.NET中编写的应用程序,可以使用单个使用者监视多个RabbitMq队列.

例如:

 using (IConnection connection = factory.CreateConnection())
{
    using (IModel channel = connection.CreateModel())
    {
        var _consumer = new QueueingBasicConsumer(channel);        
        string[] list = new string[] { "Queue1", "Queue2", "Queue3", "Queue4" };
        _consumer = new QueueingBasicConsumer(channel);
        foreach (string currQueueName in list)
        {
            channel.QueueDeclare(currQueueName, false, false, false, null);
            channel.BasicConsume(currQueueName, true, _consumer);
        }        

        while (true)
        {
            var ea = (BasicDeliverEventArgs)_consumer.Queue.Dequeue();

            var body = ea.Body;
            var message = Encoding.UTF8.GetString(body);
            Console.WriteLine(" [x] Received {0}", message);
            ProcessMessage(message);
        }
    }
}    

基本上,我只是希望能够跨多个队列分配工作,但只有一个应用程序全部使用它们(或者可以部署多个应用程序并执行相同的功能).

我正试图在队列中分散工作,以便消费者在队列中平等地工作.

这可能是使用Bunny或本机Ruby驱动程序吗？