final var rpcProxy = new ProxyDOMRpcService(actorSystem, masterReference, id,
actorResponseWaitTime);
slaveSalManager.registerSlaveMountPoint(result, masterReference, new RemoteDeviceServices(
- (Rpcs.Normalized) () -> rpcProxy,
+ new Rpcs.Normalized() {
+ @Override
+ public ListenableFuture<? extends DOMRpcResult> invokeNetconf(final QName type,
+ final ContainerNode input) {
+ return rpcProxy.invokeRpc(type, input);
+ }
+
+ @Override
+ public DOMRpcService domRpcService() {
+ return rpcProxy;
+ }
+ },
new ProxyDOMActionService(actorSystem, masterReference, id, actorResponseWaitTime)));
}
});
DOMRpcIdentifier.create(putTopRpcSchemaPath), DOMRpcIdentifier.create(getTopRpcSchemaPath));
final var rpcService = router.rpcService();
- deviceRpcService = () -> rpcService;
+ deviceRpcService = new Rpcs.Normalized() {
+ @Override
+ public ListenableFuture<? extends DOMRpcResult> invokeNetconf(final QName type, final ContainerNode input) {
+ return rpcService.invokeRpc(type, input);
+ }
+
+ @Override
+ public DOMRpcService domRpcService() {
+ return rpcService;
+ }
+ };
builderFactory = new NetconfClientConfigurationBuilderFactoryImpl(mockEncryptionService, credentialProvider,
sslHandlerFactoryProvider);
import static java.util.Objects.requireNonNull;
-import com.google.common.util.concurrent.ListenableFuture;
import org.eclipse.jdt.annotation.NonNull;
import org.eclipse.jdt.annotation.Nullable;
import org.opendaylight.mdsal.dom.api.DOMActionService;
-import org.opendaylight.mdsal.dom.api.DOMRpcResult;
import org.opendaylight.mdsal.dom.api.DOMRpcService;
-import org.opendaylight.yangtools.yang.common.QName;
-import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
/**
* Set of interfaces exposed by a {@link RemoteDevice}.
* NETCONF device RPCs operating just as any other {@link DOMRpcService}.
*/
non-sealed interface Normalized extends Rpcs {
- @Override
- default ListenableFuture<? extends DOMRpcResult> invokeNetconf(final QName type,
- final ContainerNode input) {
- return domRpcService().invokeRpc(type, input);
- }
@NonNull DOMRpcService domRpcService();
}
*/
package org.opendaylight.netconf.client.mdsal.spi;
+import com.google.common.util.concurrent.ListenableFuture;
import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.mdsal.dom.api.DOMRpcResult;
import org.opendaylight.mdsal.dom.api.DOMRpcService;
import org.opendaylight.netconf.client.mdsal.api.RemoteDeviceCommunicator;
import org.opendaylight.netconf.client.mdsal.api.RemoteDeviceServices.Rpcs;
import org.opendaylight.netconf.client.mdsal.api.RpcTransformer;
+import org.opendaylight.yangtools.yang.common.QName;
import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext;
domRpcService = new NetconfDeviceDOMRpcService(modelContext, communicator, transformer);
}
+ @Override
+ public ListenableFuture<? extends DOMRpcResult> invokeNetconf(final QName type, final ContainerNode input) {
+ return domRpcService().invokeRpc(type, input);
+ }
+
@Override
public DOMRpcService domRpcService() {
return domRpcService;