测试akka参与者时检查是否缺少日志消息

1) 创建TestKit探测器并使其订阅系统的eventStream

yourActorSystemItemTest.eventStream().subscribe(yourProbe.getRef(),UnhandledMessage.class);

然后在最后检查探测器接收到多少消息,在您的情况下为0。使用您可以使用的多种“expect…”方法之一。

2) 文档告诉您如何检查日志消息,因此只需声明您收到“意外消息”的次数为0。

祝你好运

为了提供一些细节,我需要做以下几点:

import akka.event.Logging;
import akka.testkit.javadsl.EventFilter;
import akka.testkit.javadsl.TestKit;
...

@Test
public void noUnhandledTest() {

  new TestKit(system) {{
    new EventFilter(Logging.Warning.class, system).
       occurrences(0).
       matches("unhandled event").
       intercept(() -> {
         try {
           <actual test code>

           // Intercept needs a supplier
           return 0;
         } catch (Exception e) {
           // Suppliers can't throw
           throw new RuntimeException(e);
         }
       });
  }};
}

src/test/resources/application.conf :

akka.loggers = [akka.testkit.TestEventListener ]