import static org.junit.Assert.assertNull;
import akka.actor.ActorRef;
-import akka.actor.Props;
-import akka.testkit.JavaTestKit;
import akka.testkit.TestActorRef;
+import akka.testkit.javadsl.TestKit;
import org.junit.Test;
import org.opendaylight.controller.cluster.notifications.LeaderStateChanged;
import org.opendaylight.controller.cluster.notifications.RegisterRoleChangeListener;
public class RoleChangeNotifierTest extends AbstractActorTest {
@Test
- public void testHandleRegisterRoleChangeListener() throws Exception {
- new JavaTestKit(getSystem()) {
+ public void testHandleRegisterRoleChangeListener() {
+ new TestKit(getSystem()) {
{
String memberId = "testHandleRegisterRoleChangeListener";
- ActorRef listenerActor = getSystem().actorOf(Props.create(MessageCollectorActor.class));
+ ActorRef listenerActor = getSystem().actorOf(MessageCollectorActor.props());
TestActorRef<RoleChangeNotifier> notifierTestActorRef = TestActorRef.create(getSystem(),
RoleChangeNotifier.getProps(memberId), memberId);
}
@Test
- public void testHandleRaftRoleChanged() throws Exception {
- new JavaTestKit(getSystem()) {
+ public void testHandleRaftRoleChanged() {
+ new TestKit(getSystem()) {
{
String memberId = "testHandleRegisterRoleChangeListenerWithNotificationSet";
- ActorRef listenerActor = getSystem().actorOf(Props.create(MessageCollectorActor.class));
+ ActorRef listenerActor = getSystem().actorOf(MessageCollectorActor.props());
ActorRef shardActor = getTestActor();
TestActorRef<RoleChangeNotifier> notifierTestActorRef = TestActorRef.create(getSystem(),
}
@Test
- public void testHandleLeaderStateChanged() throws Exception {
- new JavaTestKit(getSystem()) {
+ public void testHandleLeaderStateChanged() {
+ new TestKit(getSystem()) {
{
String actorId = "testHandleLeaderStateChanged";
TestActorRef<RoleChangeNotifier> notifierTestActorRef = TestActorRef.create(getSystem(),