import akka.actor.ActorRef;
import akka.testkit.javadsl.TestKit;
+import java.time.Duration;
import org.junit.Before;
import org.junit.Test;
+import org.junit.runner.RunWith;
import org.mockito.Mock;
-import org.mockito.MockitoAnnotations;
+import org.mockito.junit.MockitoJUnitRunner;
import org.opendaylight.controller.cluster.datastore.AbstractActorTest;
import org.opendaylight.controller.cluster.datastore.messages.CloseDataTreeNotificationListenerRegistration;
import org.opendaylight.controller.cluster.datastore.messages.CloseDataTreeNotificationListenerRegistrationReply;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
+@RunWith(MockitoJUnitRunner.StrictStubs.class)
public class DataTreeNotificationListenerRegistrationActorTest extends AbstractActorTest {
@Mock
private ListenerRegistration<?> mockListenerReg;
@Before
public void setup() {
- MockitoAnnotations.initMocks(this);
DataTreeNotificationListenerRegistrationActor.killDelay = 100;
kit = new TestKit(getSystem());
}
mockOnClose), ActorRef.noSender());
subject.tell(CloseDataTreeNotificationListenerRegistration.getInstance(), kit.getRef());
- kit.expectMsgClass(kit.duration("5 second"), CloseDataTreeNotificationListenerRegistrationReply.class);
+ kit.expectMsgClass(Duration.ofSeconds(5), CloseDataTreeNotificationListenerRegistrationReply.class);
verify(mockListenerReg, timeout(5000)).close();
verify(mockOnClose, timeout(5000)).run();
- kit.expectTerminated(kit.duration("5 second"), subject);
+ kit.expectTerminated(Duration.ofSeconds(5), subject);
}
@Test
kit.watch(subject);
subject.tell(CloseDataTreeNotificationListenerRegistration.getInstance(), kit.getRef());
- kit.expectMsgClass(kit.duration("5 second"), CloseDataTreeNotificationListenerRegistrationReply.class);
+ kit.expectMsgClass(Duration.ofSeconds(5), CloseDataTreeNotificationListenerRegistrationReply.class);
subject.tell(new DataTreeNotificationListenerRegistrationActor.SetRegistration(mockListenerReg,
mockOnClose), ActorRef.noSender());
verify(mockListenerReg, timeout(5000)).close();
verify(mockOnClose, timeout(5000)).run();
- kit.expectTerminated(kit.duration("5 second"), subject);
+ kit.expectTerminated(Duration.ofSeconds(5), subject);
}
@Test
verify(mockListenerReg2, timeout(5000)).close();
verify(mockOnClose2, timeout(5000)).run();
- kit.expectTerminated(kit.duration("5 second"), subject);
+ kit.expectTerminated(Duration.ofSeconds(5), subject);
}
}