I don't see how the ActorInitializationException can be related to how you do the wrapping. What is the cause of the exception? /Patrik
On Thu, Jun 12, 2014 at 7:37 PM, Luis Medina <[email protected]> wrote: > On an interesting note, it seems that if I send my actor processor a > regular non-Persistant wrapped message and then I have the actor wrap the > message in a Persistent object and send it to itself, it works! The problem > then appears to be when another actor trie to send it a Persistent message. > > Here are some additional details about my setup: > > // Setup > > ClusterSharding.get(system).start("Streams", > StreamSupervisor.props(), > new MessageExtractor()); > > > > //Sending Persistent message > > ActorRef region = ClusterSharding.get(system).shardRegion("Streams"); > region.tell(new ShardMessage(Persistent.create(props), id), self()); > > > > //MessageExtractor returns the first arg of a ShardMessage as the > entryMessage > > public class MessageExtractor implements ShardRegion.MessageExtractor { > ... > @Override > public Object entryMessage(Object message) { > if (message instanceof ShardMessage) { > return ((ShardMessage) message).getMessage(); > } else { > return message; > } > } > ... > } > > > > //StreamSupervisor > > public class StreamSupervisor extends UntypedProcessor { > ... > public static Props props() { > return Props.create(StreamSupervisor.class); > } > > @Override > public void onReceive(Object message) { > if (message instanceof Persistent) { > onMessage((Persistent) message); > } > } > > public void onMessage(Persistent message) { > Object payload = message.payload(); > > if (payload instanceof Props) { > props = (Props) payload; > > // do stuff > } > } > ... > } > > -- > >>>>>>>>>> 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 <http://www.scaladays.org/> -- >>>>>>>>>> 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.
