import static org.mockito.Mockito.timeout;
import akka.actor.ActorRef;
-import akka.testkit.JavaTestKit;
+import akka.testkit.javadsl.TestKit;
import org.junit.Before;
import org.junit.Test;
import org.mockito.Mock;
@Test
public void testOnReceiveCloseListenerRegistrationAfterSetRegistration() throws Exception {
- new JavaTestKit(getSystem()) {
+ new TestKit(getSystem()) {
{
final ActorRef subject = getSystem().actorOf(DataTreeNotificationListenerRegistrationActor.props(),
"testOnReceiveCloseListenerRegistrationAfterSetRegistration");
@Test
public void testOnReceiveCloseListenerRegistrationBeforeSetRegistration() throws Exception {
- new JavaTestKit(getSystem()) {
+ new TestKit(getSystem()) {
{
final ActorRef subject = getSystem().actorOf(DataTreeNotificationListenerRegistrationActor.props(),
"testOnReceiveSetRegistrationAfterPriorClose");
@Test
public void testOnReceiveSetRegistrationAfterPriorClose() throws Exception {
- new JavaTestKit(getSystem()) {
+ new TestKit(getSystem()) {
{
DataTreeNotificationListenerRegistrationActor.killDelay = 1000;
final ListenerRegistration<?> mockListenerReg2 = Mockito.mock(ListenerRegistration.class);