Спрошу еще проще(чтобы самому было понятнее):
1) Публикуются сообщения с заказами(1, 2 ... n) без декларирования очереди
2) Тип обменника fanout
3) В каждом потребителе создаю по одной очереди с известными именами(internal, external, mobile)
4) Запускаю эти три разных файла(воркеры?) и жду сообщений
Предположим пришло 4 заказа, все 4 потребителя их получили, потом потребитель external отвалился, но пришло еще 10 заказов, при включении потребителя external он начнет получать заказы с 5 по 14, в то время как остальные потребители уже получили заказы?
Т.е. если стартовать потребителя, забить обменник сообщениями и стопнуть потребителя, то сообщения еще будут накапливаться в обменнике, до тех пор, пока заново не запустится потребитель?
Получается в любом случае нужно знать имя очереди потребителя, очередь отправителя декларировать необязательно, запустить потребителя перед отправителем с известным именем очереди, поставить отправку сообщений отправителя и можно стопнуть потребителя и сообщения будут накапливаться в его очереди?
Написано
Войдите на сайт
Чтобы задать вопрос и получить на него квалифицированный ответ.
1) Публикуются сообщения с заказами(1, 2 ... n) без декларирования очереди
2) Тип обменника fanout
3) В каждом потребителе создаю по одной очереди с известными именами(internal, external, mobile)
4) Запускаю эти три разных файла(воркеры?) и жду сообщений
Предположим пришло 4 заказа, все 4 потребителя их получили, потом потребитель external отвалился, но пришло еще 10 заказов, при включении потребителя external он начнет получать заказы с 5 по 14, в то время как остальные потребители уже получили заказы?