Я довольно новичок в RabbitMQ, и передо мной стоит задача, которая должна быть реализована в следующих ситуациях.
У меня есть производитель RabbitMQ, который производит 2 вида сообщений (JSONObject).
Я хочу, чтобы их выбрали 2 потребителя (по одному для каждого типа сообщения). Не существует определенного порядка, в котором производитель создает и публикует сообщения.
Разработка:
- JSONObject Type 1 имеет пару ключ-значение - «service»: «service1».
JSONObject типа 2 имеет пару ключ-значение - «service»: «service2»
- Нет определенного порядка, в котором эти сообщения создаются.
- Тип 1 Сообщения должны быть использованы потребителем 1.
Предполагается, что сообщения типа 2 потребляются потребителем 2
- Если потребитель 1 не может использовать сообщение типа 1, он должен не потребляться потребителем 2. Он должен оставаться в очереди в ожидании потребителя 1.
Есть ли способ добиться этого, используя одну очередь?
Если нет, как это можно сделать?