Ошибка с DeadLetters и ActorRef

Когда вы планируете сообщение с

system.scheduler.scheduleOnce(...)

отправителем этого сообщения является DeadLetters, которому вы пытаетесь отправить сообщение в

sender ! ReturnInfluenceMessage(source)

и это также то, что говорит сообщение об ошибке.

@Martynas прав в том, что ваш sender ref будет DeadLetter ref, когда ваш код настроен так, как он есть. Основная проблема заключается в том, что вы отправляете сообщение из-за пределов системы акторов (через планировщик), а затем, когда вы используете forward, вы продолжаете распространять тот факт, что у вас нет отправителя, в следующем акторе. Вы можете исправить это, используя tell (!) вместо переадресации. Я изменил ваш пример кода, чтобы показать это (а также некоторые другие изменения, описанные после примера кода):

import akka.actor._
import concurrent.duration._

sealed trait Message
case class ReturnInfluenceMessage(source: ActorRef) extends Message
case class SetInfluences(source: ActorRef) extends Message
case object GetInfluence extends Message

class Listener extends Actor {
  def receive = {
    case ReturnInfluenceMessage(s0urce) => println(s"Listener: received influence ($s0urce)")
  }
}

class Entity extends Actor {
  val influences = context.actorOf(Props[Influences], name = "Influences")
  def receive = {
    case si @ SetInfluences(s0urce) => 
      influences ! si

    case GetInfluence => 
      influences ! GetInfluence

    case rim @ ReturnInfluenceMessage(source) =>
      source ! rim
  }
}

class Influences extends Actor {
  def receive = setInfluence

  def setInfluence:Receive = {
    case SetInfluences(s0urce)  => 
      println (s"Influences: received $s0urce")
      println (s"Influences: Influence set to $s0urce")    
      context.become(withSource(s0urce) orElse setInfluence)
  }

  def withSource(source:ActorRef):Receive = {
    case GetInfluence =>
      println (s"Influences: influence sent to $source")
      sender ! ReturnInfluenceMessage(source)      
  }    
}

object Main extends App {
  val system = akka.actor.ActorSystem("mySystem")
  val abel = system.actorOf(Props[Listener], name = "Listener")
  val cain = system.actorOf(Props[Entity], name = "Entity")

  import system.dispatcher
  system.scheduler.scheduleOnce(1500 milliseconds, cain, SetInfluences(abel))
  system.scheduler.scheduleOnce(3000 milliseconds, cain, GetInfluence)
}

Когда я запустил это, я не получил никаких мертвых писем. Другие изменения включают в себя:

• Форматирование (2 пробела для отступов, правильный регистр для var/vals)
• Изменил GetInfluence на объект дела, так как у него не было полей
• Использовалась привязка переменных в операторах case для захвата ссылки на сообщение (через символ @), когда нам нужно было отправить это сообщение вместе.
• Использована установка с двумя состояниями для актора Influences, где он сначала ожидает установки состояния (ссылка source), а затем переключается в состояние, в котором он может правильно реагировать на сообщение GetInfluences. Возможно, вы захотите явно обработать сообщение GetInfluences в начальном состоянии, так как сейчас это просто необработанное сообщение.
• Избавились от использования children.foreach, поскольку у вас уже была ссылка на единственного потомка этого актора, поэтому использование этой конструкции казалось ненужным. Я бы использовал эту конструкцию, если бы у вас было переменное количество дочерних элементов для отправки, а в этом примере у вас его нет.