Проблема с привлечением testkit eventfilter для работы, как и ожидалось ⇐ JAVA

[Anonymous]

У меня есть простой «классический» актер, который просто получает сообщение и регистрирует строку бинго для информации. В своем тесте я настраиваю инфофильтер Eventfilter, чтобы проверить вызов сообщения log.info. Отладка я вижу, что оператор журнала достигается, но тайм -аут перехвата ждет его. Примечание я могу также воссоздать это на Akka 2.6.21. < /P>
Что не так с моим тестовым кодом?package au.com.hsl.bet.pekko.bet.actors;

import org.apache.pekko.actor.UntypedAbstractActor;
import org.apache.pekko.event.Logging;
import org.apache.pekko.event.LoggingAdapter;

public class SimpleActor extends UntypedAbstractActor {

private final LoggingAdapter log = Logging.getLogger(getContext().system(), "MyLogger");

@Override
public void onReceive(Object message) throws Throwable {
log.info("Bingo");
}
}
< /code>
и тест < /p>
@Test
void Test(){

ActorSystem mySystem = ActorSystem.create("testSystem", ConfigFactory.parseString("pekko.loggers = [org.apache.pekko.testkit.TestEventListener]"));

try {
new TestKit(mySystem) {
{
TestActorRef testActor = TestActorRef.create(mySystem, Props.create(SimpleActor.class));

EventFilter
.info("Bingo",
"MyLogger",
null,
null,
1)
.intercept(
() -> {
testActor.tell("Hello", ActorRef.noSender());
return null;
},
mySystem
);
}
};
} finally {
TestKit.shutdownActorSystem(mySystem);
}
}


Подробнее здесь: https://stackoverflow.com/questions/796 ... s-expected