¿Esperando todas las respuestas de rabbitmq en un intercambio fanout?

He configurado un intercambio de fanout de rabbitmq llamado "ex_foo"para una carga de trabajo RPC. Cuando los clientes se conectan al servidor, crean su propia cola de recepción RPC no duradera y se conectan a ella con un consumidor básico. Las aplicaciones escuchan mensajes / comandos y responden a la cola definida en elreply_to parte de la solicitud.

Uno de los mensajes / comandos simples que estoy enviando el intercambio de fanout (y, por lo tanto, cada aplicación / cliente conectado a él) es un tipo demensaje de solicitud de pingy mi problema es queNo sé cuántas respuestas de ping obtendré (o debería esperar), porque no sé cuántos clientes están conectados al intercambio fanout en ningún momento. Todos los clientes conectados al intercambio fanout deben responder.

Si se entrega a 10 colas en el intercambio fanout (es decir, 10 clientes están conectados), ¿cómo sé cuántas respuestas esperar? Para saber eso, ¿tendría que saber cuántas veces se entregó? ¿Hay algo más sofisticado y un temporizador para dormir? Simplemente,mi herramienta de administración no puede simplemente esperar indefinidamente y debe cerrarse después de haber recibido todos los pings (o ha transcurrido un tiempo de espera).