[rabbitmq-discuss] Can one consumer listen to 2 queues

Fri Sep 27 08:10:48 BST 2013

I configured producer to a fanout exchange and a queue, and same with 
consumer. For some reason special messages are not broadcasted, while each 
receiver randomly receives normal messages one at a time. Can someone help 
me the loophole in my approach. Am I doing something not supposed to ?

// My producerString fanExName = "myFanEx";String qName = "myQ";
// setup
channel.queueDeclare(qName, false, false, false, null);
channel.exchangeDeclare(fanExName, "fanout");
// usageif (isSpecialMessage(msg)) {
  channel.basicPublish(fanExName, "", null, message.getBytes());} else {
  channel.basicPublish("", qName, null, message.getBytes());}
---
// My consumerString fanExName = "myFanEx";String qName = "myQ";
// setup
channel.queueDeclare(qName, false, false, false, null);
channel.exchangeDeclare(fanExName, "fanout");QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(qName, true, consumer);
channel.queueBind(qName, fanExName, "");
// usagewhile (true) {
    QueueingConsumer.Delivery delivery = consumer.nextDelivery();
    ...}

Is there a better way of doing this. I dont want all messages to reach all 
recievers irrespective of type of message.

*Update*: I tried a different approach by using one fanout exchange + 2 
queues in worker In worker, I bound a standard queue "spl-q" and a 
generated (random) queue to bind to the same fanout exchange. I did 
channel.basicConsume(queue_name, true, consumer), for both queues

This also did not work
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130927/e757a84e/attachment.htm>