[rabbitmq-discuss] Fanout exchange not playing ball?

Tim Perrett tperrett at googlemail.com
Mon May 18 22:27:03 BST 2009

Hey guys,

I've setup a fanout exchange and my expectation does not match the
output... My expectation was that using a fanout exchange all
listening clients would get all messages - however this doesn't appear
to be the case. I started two separate instances of the same
application and run the listeners - I then publish a message into the
exchange, and it appears that App1 gets a message, then App2 gets
nothing. I send another message into the queue and then App2 gets the
message but not App1 - im a little lost how this could happen?

My creation code looks like:

    val ticket = channel.accessRequest("/data")
    channel.exchangeDeclare(ticket, "mult", "topic")
    channel.queueDeclare(ticket, "mult_queue")
    channel.queueBind(ticket, "mult_queue", "mult", "example.*")
    channel.basicConsume(ticket, "mult_queue", false, new
SerializedConsumer(channel, this))

Any ideas / suggestions?

Cheers, Tim

More information about the rabbitmq-discuss mailing list