ActiveMQ - отправка сообщения определенному потребителю
Наличие единственного брокера AMQ и 100 соединенных потребителей. Я отправил бы сообщение некоторому определенному потребителю, таким образом, другие потребители не получают его (клиентская фильтрация не будет работать).
Самый простой путь состоит в том, чтобы создать виртуальные места назначения (назовите их queue:consumer-), например, и отправьте сообщения туда. Однако это приведет к 100 новым очередям, который делает это более сложным для контроля. Там какой-либо другой путь состоит в том, чтобы сделать это имеющее единственную очередь?
1 ответ
Вы можете использовать селекторы JMS .
Вы должны назначить уникальный идентификатор каждому из ваших потребителей, производитель должен будет знать об этих идентификаторах, чтобы отправлять их только конкретному потребителю. Потребители должны сотрудничать и установить селектор для приема только сообщений, предназначенных для его собственного идентификатора, а также сообщений, предназначенных для всех / любого из потребителей