Hi, any idea if that issue ended up in akka 2.4? I'm stumbling upon something similar, not sure if this is the same bug or not, when sending a Broadcast to all actors behind a consistent hashing router, I get the following error (where MyMessage is the broadcast's payload)
a.routing.ConsistentHashingRoutingLogic : Message [MyMessage] must be handled by hashMapping, or implement [akka.routing.ConsistentHashingRouter$ConsistentHashable] or be wrapped in [akka.routing.ConsistentHashingRouter$ConsistentHashableEnvelope] thanks, Assaf On Friday, January 2, 2015 at 4:09:06 PM UTC+2, Patrik Nordwall wrote: > > 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] > <javascript:>> 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] <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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
