Мне нужно переключиться с системы обмена сообщениями NATS на RabbitMQ. Текущий сценарий прост и содержит 2 основных пункта:
- в любом месте моего кода. Я публикую sh сообщение определенного типа
- все подписчиков на этот определенный тип обрабатывают сообщение.
Я понимаю, что с RabbitMQ и концепцией очередей ситуация несколько иная. Итак, мои вопросы:
1) Мне нужно смоделировать ту же концепцию, что и выше, что означает выбрасывание разных типов сообщений из разных частей кода. Нужно ли создавать одну очередь для каждого типа сообщений?
2) Я не могу создавать разных подписчиков для подписки на один и тот же тип события, но я могу заставить их прослушивать одну и ту же очередь. Проблема заключается в том, что, как только слушатель получает сообщение, сообщение должно продаваться как прочитанное, и, следовательно, другой подписчик ничего не получит. Как мне этого добиться?
заранее спасибо!