<dependency>
<groupId>com.typesafe.akka</groupId>
<artifactId>akka-testkit_2.12</artifactId>
<version>2.6.10</version>
</dependency>
import org.junit.Test;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.testkit.javadsl.TestKit;
import scala.concurrent.duration.Duration;
public class MessageDispatcherActorTest {
@Test
public void testMessageDispatcherActor() {
ActorSystem system = ActorSystem.create();
new TestKit(system) {{
ActorRef messageDispatcher = system.actorOf(Props.create(MessageDispatcherActor.class));
messageDispatcher.tell("Test Message", getRef());
expectMsg(Duration.create(1, "second"), "Message Dispatched");
}};
}
}
