Krishna, It looks like your consumers cannot keep up with your faster producer(s).
Some things to look at: 1. Make sure none of your actors are blocking. You can use VisualVM or YouKit to figure this out quickly. 2. If your actors are not blocking, you can try and add more consumer actors (using an Akka router) and see if this helps 3. Finally, you can use the new reactive streams API to add back pressure to your pipeline. HTH -Soumya On Monday, December 29, 2014 11:22:27 PM UTC-5, Krishna Kadam wrote: > > Hi all, > I am using AKKA actors for my masters project, I have a data sender > which sends message to AKKA actors, while using akka actors my machine's > RAM usage gradually increases to maximum limit. Is there any need to > manually delete the message received in AKKA actor's message queue after > processing it in OnReceive() method? > > Thanks & Regards > Krishna Kadam > -- >>>>>>>>>> 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.
