@After
public void teardown() {
- TestKit.shutdownActorSystem(slaveSystem, Boolean.TRUE);
- TestKit.shutdownActorSystem(masterSystem, Boolean.TRUE);
+ TestKit.shutdownActorSystem(slaveSystem, true);
+ TestKit.shutdownActorSystem(masterSystem, true);
}
@SuppressWarnings("unchecked")
@SuppressWarnings({ "rawtypes", "unchecked" })
@Override
- public void handleReceive(Object message) throws Exception {
+ public void handleReceive(Object message) {
CompletableFuture dropFuture = messagesToDrop.remove(message.getClass());
if (dropFuture != null) {
dropFuture.complete(message);