Hi Patrik. No, it is a basic echo test. Nevertheless the processor is not receiving any persistent message. Thanks for your comment.
El martes, 25 de marzo de 2014 10:30:57 UTC+1, Patrik Nordwall escribió: > > Eduardo, does the NIO test also use a persistent processor as destination? > /Patrik > > > On Tue, Mar 25, 2014 at 9:46 AM, Akka Team <[email protected]<javascript:> > > wrote: > >> Hi Eduardo, >> >> >> On Tue, Mar 25, 2014 at 2:08 AM, Eduardo Fernandes >> <[email protected]<javascript:> >> > wrote: >> >>> Hi all. >>> >>> I'm pretty sure this is because I don't have the correct configuration >>> on my side. Please find in the attached file a simple Eclipse Kepler Maven >>> project with an echo actor. I'm using Akka 2.3. >>> >>> The basic configuration is >>> >>> actor { >>> provider = "akka.cluster.ClusterActorRefProvider" >>> default-dispatcher { >>> throughput = 1024 >>> fork-join-executor { >>> parallelism-max = 4 >>> } >>> } >>> default-mailbox { >>> mailbox-type = "akka.dispatch.SingleConsumerOnlyUnboundedMailbox" >>> } >>> } >>> >>> Based on other thread in this group. After heating the JVM I got around >>> 11.000 msg per second. A small and basic program with NIO give me around >>> 45.000 in the same machine, using the loopback interface. >>> >> >> If you refer to the other localhost remoting benchmark thread, the >> related ticket is here: >> https://www.assembla.com/spaces/akka/simple_planner#/ticket:3960 >> >> You can check with a profiler and see if most of the time spent in >> unstash/stash in EndpointWriter to verify that it is the same issue. >> >> If you properly backpressure messages between the two nodes there should >> be no performance loss due to unstashing, you only need to increase the tcp >> send buffer. The stash/unstash death spiral only pops up because buffers >> are blowing up. >> >> >>> >>> I need to use a single actor due to processing requirements. I'm using a >>> simple sharding and a single frontend / backend topology (configured using >>> roles). >>> >>> Is it possible to flush the low level TCP channel based, for example, in >>> the volume of pending command to all actors belonging to a particular host? >>> Or is this already done based on some setting? >>> >> >> Messages are pumped out to TCP as soon as possible, there is no flushing >> involved. >> >> -Endre >> >> >>> >>> Many thanks for any help. >>> >>> Best regards, >>> >>> Eduardo. >>> >>> >>> -- >>> >>>>>>>>>> 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] <javascript:>. >>> To post to this group, send email to [email protected]<javascript:> >>> . >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Akka Team >> Typesafe - The software stack for applications that scale >> Blog: letitcrash.com >> Twitter: @akkateam >> >> -- >> >>>>>>>>>> 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] <javascript:>. >> To post to this group, send email to [email protected]<javascript:> >> . >> 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.
