package org.opendaylight.controller.cluster.datastore;
import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.eq;
import static org.mockito.Mockito.doAnswer;
import akka.util.Timeout;
import com.google.common.util.concurrent.MoreExecutors;
import com.google.common.util.concurrent.Uninterruptibles;
+import java.time.Duration;
import java.util.concurrent.TimeUnit;
import org.junit.Test;
import org.mockito.stubbing.Answer;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import scala.concurrent.ExecutionContextExecutor;
import scala.concurrent.Future;
-import scala.concurrent.duration.FiniteDuration;
public class DataTreeChangeListenerProxyTest extends AbstractActorTest {
private final DOMDataTreeChangeListener mockListener = mock(DOMDataTreeChangeListener.class);
new Thread(() -> proxy.init("shard-1")).start();
- FiniteDuration timeout = kit.duration("5 seconds");
+ Duration timeout = Duration.ofSeconds(5);
FindLocalShard findLocalShard = kit.expectMsgClass(timeout, FindLocalShard.class);
assertEquals("getShardName", "shard-1", findLocalShard.getShardName());
RegisterDataTreeChangeListener registerMsg = kit.expectMsgClass(timeout,
RegisterDataTreeChangeListener.class);
assertEquals("getPath", path, registerMsg.getPath());
- assertEquals("isRegisterOnAllInstances", false, registerMsg.isRegisterOnAllInstances());
+ assertFalse("isRegisterOnAllInstances", registerMsg.isRegisterOnAllInstances());
kit.reply(new RegisterDataTreeNotificationListenerReply(kit.getRef()));
new Thread(() -> proxy.init("shard-1")).start();
- FiniteDuration timeout = kit.duration("5 seconds");
+ Duration timeout = Duration.ofSeconds(5);
FindLocalShard findLocalShard = kit.expectMsgClass(timeout, FindLocalShard.class);
assertEquals("getShardName", "shard-1", findLocalShard.getShardName());
RegisterDataTreeChangeListener registerMsg = kit.expectMsgClass(timeout,
RegisterDataTreeChangeListener.class);
assertEquals("getPath", path, registerMsg.getPath());
- assertEquals("isRegisterOnAllInstances", true, registerMsg.isRegisterOnAllInstances());
+ assertTrue("isRegisterOnAllInstances", registerMsg.isRegisterOnAllInstances());
proxy.close();
}
new Thread(() -> proxy.init("shard-1")).start();
- FiniteDuration timeout = kit.duration("5 seconds");
+ Duration timeout = Duration.ofSeconds(5);
FindLocalShard findLocalShard = kit.expectMsgClass(timeout, FindLocalShard.class);
assertEquals("getShardName", "shard-1", findLocalShard.getShardName());
kit.reply(new LocalShardNotFound("shard-1"));
- kit.expectNoMessage(kit.duration("1 seconds"));
+ kit.expectNoMessage(Duration.ofSeconds(1));
proxy.close();
}
new Thread(() -> proxy.init("shard-1")).start();
- FiniteDuration timeout = kit.duration("5 seconds");
+ Duration timeout = Duration.ofSeconds(5);
FindLocalShard findLocalShard = kit.expectMsgClass(timeout, FindLocalShard.class);
assertEquals("getShardName", "shard-1", findLocalShard.getShardName());
kit.reply(new NotInitializedException("not initialized"));
- kit.within(kit.duration("1 seconds"), () -> {
+ kit.within(Duration.ofSeconds(1), () -> {
kit.expectNoMessage();
return null;
});
proxy.init(shardName);
- kit.expectMsgClass(kit.duration("5 seconds"), CloseDataTreeNotificationListenerRegistration.class);
+ kit.expectMsgClass(Duration.ofSeconds(5), CloseDataTreeNotificationListenerRegistration.class);
assertEquals("getListenerRegistrationActor", null, proxy.getListenerRegistrationActor());
}