Есть ли способ определить политику разделения для обменов RabbitMQ с помощью Spring AMQP? Любое исследование, которое я провел по этому вопросу, не дало мне ответа.
Проблема, с которой я сталкиваюсь, такова:
Я определил прямой обмен весной, как показано ниже:
rabbit: direct-exchange id = "pb" name = "test.pb" durable = "true"
Затем создал такую же политику для шардинга:
rabbitmqctl set_policy pbmodule-shard "^ test.pb $" "{" "shards-per-node" ":" 3 "," "ключ маршрутизации" ":" bill ""} "
После этого я отправляю сообщение:
this.rabbitTemplate.send ("test.pb", "bill", message);
То, что я увидел, было то, что сообщение было доставлено во все 3 закрытых очереди. Разве он не должен быть доставлен только одному?