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.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
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());
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());
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());
}