Akka Stopping Actors

by Online Tutorials Library July 22, 2022

Akka Stopping Actors

In Akka, you can stop Actors by invoking the stop() method of either ActorContext or ActorSystem class. ActorContext is used to stop child actor and ActorSystem is used to stop top level Actor.

The actual termination of the actor is performed asynchronously.

There are some other methods available in Akka, which are used to stop Actor. Some of which are PoisonPill, terminate() and gracefulStop() are used to stop Actor.

Akka Stopping Top Level Actor Example

You can simply call stop() method to stop top level Actor. The following example describes the uses of stop() method.

  import akka.actor.{Actor,ActorSystem, Props};    class ActorExample extends Actor{    def receive = {      case message:String => println(“Message received: “+message);      case _ => println(“Unknown message”);    }    override def postStop(){      println(“Actor stoped”);    }  }    object ActorExample{    def main(args:Array[String]){      val actorSystem = ActorSystem(“ActorSystem”);      val actor = actorSystem.actorOf(Props[ActorExample], “RootActor”);      actor ! “Hello”      actorSystem.stop(actor);    }  }  

Output:

Message received: Hello  Actor stoped

Akka Stopping Child Actor Example

  import akka.actor.{Actor,ActorSystem, Props};    class ActorExample extends Actor{    def receive = {      case message:String => println(“Message received by “+self.path.name+”: “+message);      val childactor = context.actorOf(Props[ChildActor], “ChildActor”);      childactor ! “Hello child Actor”      context.stop(childactor);            case _ => println(“Unknown message”);    }  }      class ChildActor extends Actor{    def receive = {      case message:String => println(“Message received by “+self.path.name+”: “+message);      case _ => println(“Unknown message”);    }        override def postStop(){      println(“Child Actor stoped”);    }  }      object ActorExample{    def main(args:Array[String]){      val actorSystem = ActorSystem(“ActorSystem”);      val actor = actorSystem.actorOf(Props[ActorExample], “RootActor”);      actor ! “Hello”          }  }  

Output:

Message received by RootActor: Hello  Message received by ChildActor: Hello child Actor  Child Actor stoped