Java 8 和 Akka 2.12:2.5.16 在这里。我正在尝试利用Akka TestKit编写我的第一个(有史以来)Akka 单元测试,并且正在努力应用我在网上找到的(极少数)示例中看到的原则。
我的演员:
public class Child extends AbstractActor {
@Override
public Receive createReceive() {
return receiveBuilder()
.match(Init.class, init -> {
int workUnit = workService.doSomeWork();
log.info("Performed work on {}", workUnit);
}).build();
}
}
public class Master extends AbstractActor {
@Inject @Named("CHILD")
private ActorRef child;
@Override
public Receive createReceive() {
return receiveBuilder()
.match(Init.class, init -> {
child.tell(init, self());
}).build();
}
}
非常非常简单。所以现在我只想编写一个单元测试来验证当Master
actor收到Init
消息时,它是否将该消息转发给它的Child
actor。迄今为止我最好的尝试:
@RunWith(MockitoJUnitRunner.class)
public class MasterTest {
private ActorSystem actorSystem;
@Before
public void setup() {
actorSystem = ActorSystem.create("test-system");
}
@After
public void teardown() {
Duration duration = Duration.create(10L, TimeUnit.SECONDS);
TestKit.shutdownActorSystem(actorSystem, duration, true);
actorSystem = null;
}
@Test
public void onInit_shouldSendFordwardToChild() {
// Given
TestKit testKit = new TestKit(actorSystem);
ActorRef master = actorSystem.actorOf(Props.create(Master.class, testKit));
// When
master.tell(new Init(), ActorRef.noSender());
// Then
testKit.expectMsg(Init.class);
}
}
当我运行它时,我得到:
java.lang.IllegalArgumentException: no matching constructor found on class com.me.myapp.Master for arguments [class akka.testkit.TestKit]
有人可以帮我将TestKit
实例连接到我的Master
演员中,并帮助我弄清楚如何重构MasterTest
以验证我想要完成的事情吗?提前致谢!