Я настроил обмен вентиляторами rabbitmq под названием "ex_foo"для рабочей нагрузки RPC. Когда клиенты подключаются к серверу, они создают свою собственную недолговременную очередь приема RPC и подключаются к ней с помощью BasicConsumer. Приложения прослушивают сообщения / команды и отвечают на очередь, определенную вreply_to часть запроса.

Одна из простых сообщений / команд, которую я рассылаю через разветвленный обмен (и, таким образом, каждое приложение / клиент, подключенный к нему), представляет собой типсообщение запроса пингаи моя проблема в том, чтоЯ не знаю, сколько пинг-ответов я получу (или следовало ожидать), потому что я не знаю, сколько клиентов подключено к разветвленному обмену одновременно. Все клиенты, подключенные к фанатской бирже, должны ответить.

Если получено 10 очередей на разветвленном обмене (т. Е. Подключено 10 клиентов), как узнать, сколько ответов ожидать? Чтобы узнать это, нужно ли мне знать, сколько раз оно было доставлено? Есть ли что-нибудь более сложное и таймер сна? Просто,мой инструмент администратора не может просто ждать бесконечно и должен выйти после того, как он восстановил все пинги (или истекло время ожидания).