This may be an issue with asynchronous or message-passing based programming in general...I hope someone can help out...<br><br>Basically, I want to send out a query in the form of an AMQ message and receive back responses from an unknown and possibly large number of responders.<br>
<br>As an example, let's say we're doing some game logic and we want to figure out if an action should succeed or not.<br><br>My idea was to publish a message to a topic exchange with a routing key like "magic.success.<characterName>" and then collect all the responses from all the subscribed subsystems and use their responses to decide if the action succeeded or not. It's almost like a map-reduce I guess.<br>
<br>It seems like I would either need to set a timeout after which I stop waiting for responses (seems wasteful and possibly non-deterministic if some logic takes unusually long to run)<br><br>or I somehow need to know in advance how many consumers there are, OR I need to know how many queues my initial message got delivered to.<br>
<br>Has anyone dealt with something like this before?<br><br><br><br><br>