Akka JavaStkit JUnit消息未发送给默认/用户

Question

我正在使用JavaStkit编写一个Akka JUnit测试，并试图找出我做错了什么。

ActorSystem akkaSystem = ActorSystem.create("myAkkaSystem");

Props executiveProps = Props.create(ExecutiveSupervisor.class);
TestActorRef<ExecutiveSupervisor> executiveSupervisorTestActorRef = TestActorRef.create(akkaSystem, executiveProps, "testExecutiveSupervisor");

new JavaTestKit(akkaSystem) {{

    final Inbox inbox = Inbox.create(akkaSystem);
    inbox.send(executiveSupervisorTestActorRef, new Object());
    ResultAndData result = (Object)inbox.receive(Duration.create(2, TimeUnit.SECONDS));

 }};

执行通过演员中的代码非常愉快。在worker中的某一点上，我希望它在ActorSystem级别将传递的相同对象（ResultAndData）返回到JUnit的收件箱。即。我希望worker将传递给它的对象返回给其父级。

但是，就像它试图返回下面的行一样：

log.info("SUCCESS!!!!!!!!!!!");
getContext().parent().tell(result, getSelf());  //FAILS HERE

此时我得到以下消息：

expectMsgEquals(duration("2 seconds"), result);

谢谢大家，任何帮助都很好。

Answer 1

您应该这样返回消息：

sender().tell(result, getSelf());

现在您正在将消息发送给您的演员的父级，因为您的演员是顶级演员，这将不会成功。您的参与者的父级不是收件箱，因此您尝试的内容无法成功。父角色是在上下文中创建子角色的角色，当您通过actorSystem上的TestActorRef创建角色时，它将是一个顶级角色，将default/user角色作为父角色，您不能使用它来接收消息。我怀疑您真正想要的是响应消息，因此您应该将消息发送给当前消息的发送者，您可以使用sender()检索该消息。