Hi Chanan, context().sender() returns the sender of the message which is currently being handled by the actor. So calling that from SupervisorStrategy returns the sender of the failure message which is the failed actor.
If you want to notify the original sender, I suggest to do that from the worker. So instead of throwing an exception it would stop processing the current message and send a message to an original sender indicating a failure. On Mon, Jul 7, 2014 at 11:22 PM, Chanan Braunstein < [email protected]> wrote: > Hi, > > I am trying to understand how to get the sender of the failed message in a > supervisor. In this sample, there is a service that changes a string to > upper case. I would like to return a "FailureToUpResponse" when the worker > throws an exception. The service itself is being called from an ask from a > play controller. Instead of getting the above class, I get a timeout. The > line that I know is wrong is: context().sender().tell(new > FailureToUpResponse(), self()); <- which returns the worker class and not > the controller, but I cannot figure out the correct syntax. Here is the > full class: > > public class ServiceActor extends AbstractActor { > private int count = 0; > > public ServiceActor() { > receive( > ReceiveBuilder.match(ServiceActor.ToUpperRequest.class, > request -> { > Logger.debug("About service: " + self().toString() + " > Thread: " + Thread.currentThread().getName()); > count++; > final ActorRef worker = > context().actorOf(Props.create(Worker.class, count)); > worker.forward(request, context()); > }).build() > ); > } > > private SupervisorStrategy strategy = > new OneForOneStrategy(10, Duration.create("1 minute"), > DeciderBuilder. > match(IllegalArgumentException.class, e -> { > Logger.debug("E: " + e); > context().sender().tell(new FailureToUpResponse(), > self()); > return stop(); > }). > matchAny(o -> escalate()).build()); > > @Override > public SupervisorStrategy supervisorStrategy() { > return strategy; > } > > > public static class Worker extends AbstractActor { > public Worker(int count) { > receive( > > ReceiveBuilder.match(ServiceActor.ToUpperRequest.class, request -> { > Logger.debug("About me: " + self().toString() + " > Thread: " + Thread.currentThread().getName()); > if(request.input.equals("error")) throw new > IllegalArgumentException("Cannot handle the word error!"); > Thread.sleep(5000); > Logger.debug("Did the work: " + > request.input.toUpperCase() + "-" + count); > final ToUpperResponse response = new > ToUpperResponse(request.input, request.input.toUpperCase() + "-" + count); > sender().tell(response, self()); > context().stop(self()); > }).build() > ); > } > } > > public static class ToUpperRequest { > public final String input; > > public ToUpperRequest(String input) { > this.input = input; > } > } > > public static class ToUpperResponse { > public final String input; > public final String output; > > public ToUpperResponse(String input, String output) { > this.input = input; > this.output = output; > } > } > > public static class FailureToUpResponse { > > } > } > > -- > >>>>>>>>>> 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. > -- Martynas Mickevičius Typesafe <http://typesafe.com/> – Reactive <http://www.reactivemanifesto.org/> Apps on the JVM -- >>>>>>>>>> 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.
