You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.queueDeclare(queue, plugin.isDurable(), false, false, null);
// Why queue and exchange have the same name? in my case, they must be different.
channel.queueBind(queue, queue, routingKey);
how i make work of exchange(type direct) is correct?
The text was updated successfully, but these errors were encountered:
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);
channel.queueDeclare(queue, plugin.isDurable(), false, false, null);
// Why queue and exchange have the same name? in my case, they must be different.
channel.queueBind(queue, queue, routingKey);
how i make work of exchange(type direct) is correct?
The text was updated successfully, but these errors were encountered: