X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdom%2Fbroker%2FMountPointImpl.java;h=623bbdb19514ce15ffa0b9102959fbac77cb51d2;hb=5109d42de3cfd06bb3834b7f6fc9e4ab6e8bb3d2;hp=dc554a072769ae0ecadf74601aa059cdbfc2d4eb;hpb=f9aae7377704eed8a43c9a984f585165042ce5f7;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointImpl.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointImpl.java index dc554a0727..623bbdb195 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointImpl.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/MountPointImpl.java @@ -9,7 +9,6 @@ package org.opendaylight.controller.sal.dom.broker; import java.util.List; import java.util.Set; -import java.util.concurrent.Future; import org.opendaylight.controller.md.sal.common.api.RegistrationListener; import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler; @@ -41,6 +40,8 @@ import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.PathArgument; import org.opendaylight.yangtools.yang.model.api.SchemaContext; +import com.google.common.util.concurrent.ListenableFuture; + public class MountPointImpl implements MountProvisionInstance, SchemaContextProvider { private final SchemaAwareRpcBroker rpcs; @@ -122,9 +123,8 @@ public class MountPointImpl implements MountProvisionInstance, SchemaContextProv return rpcs.getSupportedRpcs(); } - @Override - public RpcResult invokeRpc(QName rpc, CompositeNode input) { + public ListenableFuture> invokeRpc(QName rpc, CompositeNode input) { return rpcs.invokeRpc(rpc, input); } @@ -133,10 +133,9 @@ public class MountPointImpl implements MountProvisionInstance, SchemaContextProv return rpcs.addRpcRegistrationListener(listener); } - @Override - public Future> rpc(QName type, CompositeNode input) { - return null; + public ListenableFuture> rpc(QName type, CompositeNode input) { + return rpcs.invokeRpc( type, input ); } @Override @@ -227,6 +226,4 @@ public class MountPointImpl implements MountProvisionInstance, SchemaContextProv L listener) { return rpcs.registerRouteChangeListener(listener); } - - }