Akka消息未送达

Question

我有一个PropertiesStoreactor，它持有一个可变表。通过rest API操作的运行时配置的缓冲区。您可以使用以下对象从所述商店进行读写：

Read（无，属性（key=“MyConfigKey”，value=None））

存储以Property及其值响应。

为了方便找到这家店，我有另一个演员（一个客串），我在飞行中创造：

object PropertyLookup {
  def apply(propertyKey: String, target: Option[ActorRef]): Props = {
    Props(new PropertyLookup(propertyKey, target))
  }
}

class PropertyLookup(key: String, target: Option[ActorRef]) extends Actor with ActorLogging {
  val PropertiesStore = "/user/Master/DataStore/PropertiesStore"
  val propertiesActor = context.actorSelection(PropertiesStore)

  def receive: Actor.Receive = {
    case _=>
      log.info(s"Looking up ${key} via ${propertiesActor}")
      propertiesActor.tell(Read(None, Property(key, None)), target.getOrElse(sender()))
      log.info(s"Sent property lookup to PropertiesStore: ${key}")
//      context.stop(self)
  }
}

这使我能够将所述参与者的“定位”（即通过其路径）保持在一个位置，避免在移动时进行过多的返工。此属性查找有一个可选的目标参与者，一旦执行查找，属性存储将将结果发送到该参与者。在我做一些工作之前，我在另一个参与者中使用所有这些来获取配置值：

  context.actorOf(PropertyLookup(PropertyKeys.SpreadsheetURL, None), s"PropertiesLookup_${self.path.name}") ! None

但当我这么做时，我得到了以下警告：

来自参与者的消息[domain.Read][akka://NN/user/$a/Master/DataStore/PlayerStore#-1100303450]给演员[akka://NN/user/Master/DataStore/PropertiesStore]没有送达。[2] 遇到死信。可以使用配置设置“akka”关闭或调整此日志记录。记录死信和阿克卡。关闭期间记录死信'

而且我从来没有在被调用者中收到过我的Property实例。cameo（Property tyLookup的实例）确实做了它的事情并记录了日志，所以我知道该部分正在工作。

发生了什么事？我的客串全错了吗？有更好的方法吗？我如何理解这个警告周围发生了什么

Answer 1

你的代码和日志输出是最新的吗？首先你给出了Read as的定义

Read(Property(key ="MyConfigKey", value = None))

但你却把它当作

Read(None, Property(key, None))

其次，您正在创建名为“PropertiesLookup_${self.path.name}”的actor。但您的日志输出显示，此参与者名称不包含“PropertiesLookup”字符串。

此外，请注意，您记录的路径包括一个$a，这表明路径中实际上有一个匿名参与者，而这不是actorSelection调用中的内容。