Akka Kill vs. Stop vs. Poison Pill?

by

Both stop and PoisonPill will terminate the actor and stop the message queue. They will cause the actor to cease processing messages, send a stop call to all its children, wait for them to terminate, then call its postStop hook. All further messages are sent to the dead letters mailbox.

The difference is in which messages get processed before this sequence starts. In the case of the stop call, the message currently being processed is completed first, with all others discarded. When sending a PoisonPill, this is simply another message in the queue, so the sequence will start when the PoisonPill is received. All messages that are ahead of it in the queue will be processed first.

By contrast, the Kill message causes the actor to throw an ActorKilledException which gets handled using the normal supervisor mechanism. So the behaviour here depends on what you’ve defined in your supervisor strategy. The default is to stop the actor. But the mailbox persists, so when the actor restarts it will still have the old messages except for the one that caused the failure.

Also see the ‘Stopping an Actor’, ‘Killing an Actor’ section in the docs:

http://doc.akka.io/docs/akka/snapshot/scala/actors.html

And more on supervision strategies:

http://doc.akka.io/docs/akka/snapshot/scala/fault-tolerance.html

More Related Contents:

  1. sender inside a future
  2. No configuration setting found for key ‘akka.version’
  3. How to create a Source that can receive elements later via a method call?
  4. Accessing the underlying ActorRef of an akka stream Source created by Source.actorRef
  5. How to restrict actor messages to specific types?
  6. What is the purpose of type ascriptions in Scala?
  7. What is the advantage of using abstract classes instead of traits?
  8. Provide schema while reading csv file as a dataframe
  9. How to flatmap a nested Dataframe in Spark
  10. Scala return statements in anonymous functions
  11. What is the difference between `##` and `hashCode`?
  12. Scala: Why does Seq.contains take an Any argument, instead of an argument of the sequence type?
  13. Customize SparkContext using sparkConf.set(..) when using spark-shell
  14. When to use val or def in Scala traits?
  15. What are the differences between asInstanceOf[T] and (o: T) in Scala?
  16. Cake pattern with overriding abstract type don’t work with Upper Type Bounds
  17. Overload constructor for Scala’s Case Classes?
  18. Scala Sets contain the same elements, but sameElements() returns false
  19. What is the type of a variable-length argument list in Scala?
  20. How to compute cumulative sum using Spark
  21. using variable length argument in scala
  22. Underscore in List.filter
  23. Add Number of days column to Date Column in same dataframe for Spark Scala App
  24. ScalaTest in sbt: is there a way to run a single test without tags?
  25. How to reference external sbt project from another sbt project?
  26. Missing parameter type error by calling toSet?
  27. Dynamically compiling scala class files at runtime in Scala 2.11
  28. How to vectorize DataFrame columns for ML algorithms?
  29. Getting subclasses of a sealed trait
  30. How to instantiate an instance of type represented by type parameter in Scala

Leave a Comment