Hi, I'm implementing a "work pulling" system over akka, where a "dispatcher" talks to a bunch of remote "workers", basically: - the dispatcher sends each worker a "workAvailable" message - the worker replies to "workaAvailable" with a "get" request - the dispatcher sends the workload, which can be a few 10MB
Having the workload on shared storage is not what we want to do. For messages exceeding a max size we can implement streaming but it's out of scope of this question. My problem is to limit the parallelization of the outgoing messages: as the number of clients increases, my dispacther is trying to send as many workload messages in parallel and I end up with an OutOfMemoryError. My understanding is that we can configure the "input" mailboxes of actors, but here there's never more than one item in my recipient's mailbox, it's the number of recipients that grows, and I want to make sure I don't send more than one message at a time (or at least not more than what my memory can handle!) Is there a way ton configure or override this in Akka? Thanks, Arjun -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>>>>>>>>> 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/groups/opt_out.
