Dead letter in Akka Scala actors

I have a very simple structure based on Akka actors in Scala, but I keep getting warnings about undeliverable messages. This is the code for the main class, Collector is a separate class that extends Actor:

object Executor extends App {

  class ExecutorMaster extends Actor {

    def receive() = {
      case _ => Executor.actorSystem.actorOf(Props[Collector], name = "Collector") ! true
    }

  }

  val actorSystem = ActorSystem("ReadScheduler")
  private val app = actorSystem.actorOf(Props[ExecutorMaster], name = "Executor")

  app ! true

}

The message is not delivered to the collector, the result for the code is:

[27.04.2014 18: 09: 05.518] [ReadScheduler-akka.actor.default-dispatch-3] [akka: // ReadScheduler / user / Collector] Message [java.lang.Boolean] from Actor [akka: // ReadScheduler / user / artist # 2127791644] Actor [akka: // ReadScheduler / user / Collector # 337715308] was not delivered. [1] Dead letters found. This log can be turned off or configured with the configuration settings akka.log-dead-letters and akka.log-dead-letters-while-shutdown.

? -, ?

+4
1

- , Collector ExecutorMaster.

, receive, - , , , ExecutorMaster.

:

val collector = context.actorOf(Props[Collector], name = "Collector")
def receive = {
    case _ => collector ! true
}

case object, , true.

+3

Source: https://habr.com/ru/post/1538303/


All Articles