In general a variation of the work pulling pattern helps to pull only as much data as you need to the other node: See here: http://doc.akka.io/docs/akka/snapshot/scala/howto.html
On Mon, Jun 22, 2015 at 7:23 AM, Vishnu Sharavan Nag < [email protected]> wrote: > Patrik, > > Any suggestions towards implementing the flow control in remote > connections? > > Regards, > Vishnu > > On Friday, 19 June 2015 11:47:14 UTC+5:30, Vishnu Sharavan Nag wrote: >> >> Thanks Patrik. I'll look into it. >> >> On Wednesday, 17 June 2015 17:51:56 UTC+5:30, Patrik Nordwall wrote: >>> >>> I would guess that you are filling up the tcp buffer, and then Akka will >>> back-off and start buffering the messages. Maybe you can see this log >>> message: >>> >>> log.warning("[{}] buffered messages in EndpointWriter for >>> [{}]. " + >>> "You should probably implement flow control to avoid >>> flooding the remote connection.", >>> size, remoteAddress) >>> >>> My advice is the same as that log message. >>> >>> Regards, >>> Patrik >>> >>> On Tue, Jun 16, 2015 at 12:47 PM, Vishnu Sharavan Nag < >>> [email protected]> wrote: >>> >>>> Hi..I have two actor systems that are connected remotely. If am trying >>>> to transfer a large number of messages from one to another, does >>>> introducing a delay in between the messages reduce the average transfer >>>> time per message? >>>> I find that the average transfer time reduces if there is a small delay >>>> between the messages than when the messages are sent one after the other >>>> without any delay between them. >>>> Any explanation for this? >>>> >>>> Thanks in advance! >>>> >>>> -- >>>> >>>>>>>>>> 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. >>>> >>> >>> >>> >>> -- >>> >>> Patrik Nordwall >>> Typesafe <http://typesafe.com/> - Reactive apps on the JVM >>> Twitter: @patriknw >>> >>> -- > >>>>>>>>>> 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. > -- Cheers, Konrad 'ktoso' Malawski Akka <http://akka.io/> @ Typesafe <http://typesafe.com/> -- >>>>>>>>>> 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.
