RabbitMQ RPC с проблемой обмена
Поэтому я следовал этому руководству: http://www.rabbitmq.com/tutorials/tutorial-six-java.html, но не могу заставить его работать с прямым обменом.
Может кто-нибудь помочь мне, пожалуйста, изменив код так, чтобы он работал с прямым обменом.
Моя цель: пользователь может выбрать, на какую машину отправлять. Когда он решит, я хочу привязать эту машину и просто отправить ее на эту машину. Но, кажется, это не работает, когда я изменяю очередь, объявляют об обмене, объявляют. Любая помощь будет очень ценится!!!
Спасибо
1 ответ
В RabbitMQ вы публикуете сообщения для бирж, поэтому код, который вы видите в руководстве: channel.basicPublish("", "rpc_queue", props, message.getBytes());
, означает: отправить сообщение на биржу ""
, используя ключ маршрутизации "rpc_queue"
, Это обмен по умолчанию или анон, обсуждаемый в первом уроке.
Поэтому, если вы хотите отправить сообщение на прямой обмен, просто измените пустое имя обмена на свое имя обмена.
Теперь, почему вы хотите сделать это таким образом? Почему ты не можешь вместо того, чтобы объявить "rpc_queue"
вы объявляете очередь на машину и адресуете их по именам, в basicPublish
?