Hi Eugene, That should be fixed. I have created an issue. https://github.com/akka/akka/issues/16611
Thanks for reporting. /Patrik On Thu, Dec 25, 2014 at 7:59 PM, Dmitry Semenov <[email protected]> wrote: > Not sure if it relative to the problem you want to solve, but you can do > following stuff to get all routees > > def guardianReceive: Actor.Receive = { > case DiscoverChildren ⇒ > router ! GetRoutees > case Routees(routees) => > routees.foreach { > case ActorRefRoutee(ref) => addWorker(ref) > ref ! GuardianRegistration > } > } > > > > On Wednesday, December 24, 2014 5:12:39 PM UTC-5, Eugene Dzhurinsky wrote: >> >> I'm trying to create a simple proof of concept for working with a group >> of actors in a cluster. >> >> I've created the following example >> >> https://gist.github.com/jdevelop/b57c9b1b0e0063b4ccc1 >> >> the problem is - sending a *Broadcast* message to a >> *consistent-hashing-group* router, obtained from the cluster >> configuration - seems to send a message only to a single routee - not all >> of them. >> >> The sample output from the code above: >> >> Started akka://Test/user/routeeA/$h >> Started akka://Test/user/routeeA/$i >> Started akka://Test/user/routeeA/$f >> Started akka://Test/user/routeeA/$j >> Started akka://Test/user/routeeA/$a >> Started akka://Test/user/routeeA/$g >> Started akka://Test/user/routeeA/$b >> Started akka://Test/user/routeeA/$c >> Started akka://Test/user/routeeA/$e >> Started akka://Test/user/routeeA/$d >> Started akka://Test/user/splitter/$b >> Started akka://Test/user/splitter/$a >> Received data to process >> Broadcasting work for akka://Test/user/routerA >> Received broadcast from akka.tcp://[email protected]:2552/user/splitter/$a >> Worker Actor[akka.tcp://[email protected]:2551/user/routeeA/$a#410953742] >> wants some data >> Process to respond akka.tcp://[email protected]:2552/user/splitter/$a >> Worker Actor[akka.tcp://[email protected]:2551/user/routeeA/$a#410953742] >> completes its job >> >> >> As it is seen - the only one actor receives the broadcast message - not >> 10, which is weird. >> >> Can you please advice how to fix that (without using >> DistributedPubSubMediator)? >> >> Thank you! >> > -- > >>>>>>>>>> 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.
