import org.opendaylight.controller.cluster.datastore.shardstrategy.DefaultShardStrategy;
import org.opendaylight.controller.cluster.datastore.shardstrategy.ShardStrategy;
import org.opendaylight.controller.cluster.datastore.shardstrategy.ShardStrategyFactory;
-import org.opendaylight.controller.cluster.datastore.utils.ActorContext;
+import org.opendaylight.controller.cluster.datastore.utils.ActorUtils;
import org.opendaylight.controller.cluster.datastore.utils.MockConfiguration;
import org.opendaylight.controller.cluster.raft.utils.DoNothingActor;
import org.opendaylight.controller.md.cluster.datastore.model.CarsModel;
import org.slf4j.LoggerFactory;
import scala.concurrent.Await;
import scala.concurrent.Future;
-import scala.concurrent.duration.Duration;
+import scala.concurrent.duration.FiniteDuration;
/**
* Abstract base class for TransactionProxy unit tests.
@Override
public YangInstanceIdentifier getPrefixForPath(final YangInstanceIdentifier path) {
- return YangInstanceIdentifier.EMPTY;
+ return YangInstanceIdentifier.empty();
}
}).put(
CarsModel.BASE_QNAME.getLocalName(), new ShardStrategy() {
@Override
public YangInstanceIdentifier getPrefixForPath(final YangInstanceIdentifier path) {
- return YangInstanceIdentifier.EMPTY;
+ return YangInstanceIdentifier.empty();
}
}).build();
};
@Mock
- protected ActorContext mockActorContext;
+ protected ActorUtils mockActorContext;
protected TransactionContextFactory mockComponentFactory;
for (Future<?> future : proxy.getCohortFutures()) {
assertNotNull("Ready operation Future is null", future);
try {
- futureResults.add(Await.result(future, Duration.create(5, TimeUnit.SECONDS)));
+ futureResults.add(Await.result(future, FiniteDuration.create(5, TimeUnit.SECONDS)));
} catch (Exception e) {
futureResults.add(e);
}