feliperazeek/play-rabbitmq — Issue #6: exchange type "direct" not work correctly
Author: kolprogman
Created: 2011-10-18 06:19:39+00:00
State: open

Troulble description:
i need route messages via "routing key" and exchange type "direct". Messages sent to common queue . I use class extends RabbitMQFirehose for publishing messages. for route opportunity i override method String routingKey(T t);
also, i extends class RabbitMQConsumer and override method String routingKey(T t); after run my project, messages sent to common queue. Message delivery to any consumers and processed him, "routing key" ignored.

important:
i use single common queue.
all messages sent to common queue.
consumer take message by "routig key".

May be error in "Channel createChannel(String queue, String routingKey)" method in RabbitMQPlugin.java.

channel.exchangeDeclare(queue, plugin.getExchangeType(), true);
// queue must be declared?
channel.queueDeclare(queue, plugin.isDurable(), false, false, null);

channel.queueBind(queue, queue, routingKey);

how i make work of exchange(type direct) is correct?