Eu configurei uma troca de fanout rabbitmq chamada "ex_foo"para uma carga de trabalho RPC. Quando os clientes se conectam ao servidor, eles criam sua própria fila de recebimento RPC não durável e se conectam a ele com um BasicConsumer. Os aplicativos ouvem mensagens / comandos e respondem à fila definida no diretórioreply_to parte da solicitação.

Uma das mensagens / comandos simples que estou enviando para a troca de fanout (e, portanto, todo aplicativo / cliente conectado a ela) é um tipo demensagem de solicitação de ping, e meu problema é queNão sei quantas respostas de ping receberei (ou deveria esperar), porque não sei quantos clientes estão conectados à troca de fanout ao mesmo tempo. Todos os clientes conectados à troca de fanout devem responder.

Se for entregue em 10 filas na troca de fanout (ou seja: 10 clientes estão conectados), como sei quantas respostas esperar? Para saber isso, eu precisaria saber quantas vezes ele foi entregue? Existe algo mais sofisticado e um temporizador? Simplesmente,minha ferramenta de administração não pode esperar indefinidamente e precisa sair depois de recuperar todos os pings (ou um tempo limite expirou).