scala – 记录发送到Akka TestKit TestProbe的所有消息

发布时间：2020-12-16 09:01:29 所属栏目：安全来源：网络整理

导读：我正在尝试记录TestKit TestProbe收到的所有消息,这被证明有点困难.我知道文档中的 Actor Logging部分,它说应该将debug.receive选项与LogginReceive块结合使用.然而,当我无法控制演员的实现时,这不起作用. 我唯一的想法是将akka.testkit.TestActor子类化为使

我正在尝试记录TestKit TestProbe收到的所有消息,这被证明有点困难.我知道文档中的 Actor Logging部分,它说应该将debug.receive选项与LogginReceive块结合使用.然而,当我无法控制演员的实现时,这不起作用.

我唯一的想法是将akka.testkit.TestActor子类化为使用LoggingReceive,然后继承TestKit,使其创建我的TestActor子类的实例,但这不起作用,因为大多数功能都是akka命名空间的私有(并且用于我猜想有充分的理由).

解决方法

对不起,一开始你的问题有点不对,所以这是我的方法.

创建一个记录消息的包装器actor：

class LoggingActor(fac: => Actor) extends Actor {

  val underlying = context.system.actorOf(Props(fac))

  def receive = {
    LoggingReceive {
      case x ? underlying.tell(x,sender)
    }
  }
}

然后用你的actor包装在LoggingActor中创建你的TestActorRef：

val echo = TestActorRef(new LoggingActor(new FooActor))

  echo ! "hello world"

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!