import akka.util.Timeout;
import com.google.common.util.concurrent.ListenableFuture;
import java.net.InetSocketAddress;
-import java.util.Collections;
+import java.util.List;
import java.util.Optional;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.mdsal.common.api.ReadFailedException;
import org.opendaylight.netconf.api.DocumentedException;
-import org.opendaylight.netconf.sal.connect.api.RemoteDeviceId;
+import org.opendaylight.netconf.client.mdsal.api.RemoteDeviceId;
import org.opendaylight.netconf.topology.singleton.messages.NormalizedNodeMessage;
import org.opendaylight.netconf.topology.singleton.messages.netconf.CommitRequest;
import org.opendaylight.netconf.topology.singleton.messages.netconf.CreateEditConfigRequest;
public class ProxyNetconfServiceTest {
private static final RemoteDeviceId DEVICE_ID =
new RemoteDeviceId("dev1", InetSocketAddress.createUnresolved("localhost", 17830));
- private static final YangInstanceIdentifier PATH = YangInstanceIdentifier.empty();
+ private static final YangInstanceIdentifier PATH = YangInstanceIdentifier.of();
private static final LogicalDatastoreType STORE = LogicalDatastoreType.CONFIGURATION;
private static ActorSystem system = ActorSystem.apply();
throws InterruptedException, ExecutionException, TimeoutException {
final ListenableFuture<?> submit = netconf.commit();
masterActor.expectMsgClass(CommitRequest.class);
- masterActor.reply(new InvokeRpcMessageReply(null, Collections.emptyList()));
+ masterActor.reply(new InvokeRpcMessageReply(null, List.of()));
submit.get(5, TimeUnit.SECONDS);
}
assertEquals(ErrorTag.OPERATION_FAILED, de.getErrorTag());
assertEquals(ErrorType.APPLICATION, de.getErrorType());
}
-}
\ No newline at end of file
+}