Hello! I need to build up a cluster, which consists of a hierarchy of 'worker' actors. requesting some data from 'producers' and then sinking it to 'consumers'.
Actors are started on nodes of certain types using *Group* router, so upon the startup the appropriate actors are started on a 'worker', 'producer' or 'consumer' nodes. I need to get references to those "group" routers: - workers need to know where producers are. to pull work from one of them - consumers needs to know the same about the workers to get the results At this point it's a bit unclear what is the best way of linking actors among themselves - a single worker should "ask" for an input from *all* producers - that means sending some "Ask" request, then if producer doesn't have anything - it should simply ignore the request, otherwise it should send back the 'data' object. But if more than one producer will receive the request - then worker will receive 2 responses. So an "acknowledge" is required, which complicates things. Please advice, perhaps I miss something and it is possible to have some distributed queue which guarantees that only one response will be received upon request? Thanks! -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
