Change DOM invokeRpc to FluentFuture

[mdsal.git] / dom / mdsal-dom-spi / src / main / java / org / opendaylight / mdsal / dom / spi / RpcRoutingStrategy.java

diff --git a/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/RpcRoutingStrategy.java b/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/RpcRoutingStrategy.java
index 3d2d297e0afe79eea7386eea0d253cdbb9459461..6a60e0c222cf6cf293f35d0e36b74cd1a46f0dcb 100644 (file)
--- a/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/RpcRoutingStrategy.java
+++ b/dom/mdsal-dom-spi/src/main/java/org/opendaylight/mdsal/dom/spi/RpcRoutingStrategy.java
@@ -11,7 +11,6 @@ import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 import org.opendaylight.yangtools.concepts.Identifiable;
 import org.opendaylight.yangtools.yang.common.QName;
-import org.opendaylight.yangtools.yang.model.api.ContainerSchemaNode;
 import org.opendaylight.yangtools.yang.model.api.DataSchemaNode;
 import org.opendaylight.yangtools.yang.model.api.RpcDefinition;
 import org.opendaylight.yangtools.yang.model.api.UnknownSchemaNode;
@@ -55,13 +54,10 @@ public abstract class RpcRoutingStrategy implements Identifiable<QName> {
     public abstract boolean isContextBasedRouted();
 
     public static RpcRoutingStrategy from(final RpcDefinition rpc) {
-        ContainerSchemaNode input = rpc.getInput();
-        if (input != null) {
-            for (DataSchemaNode schemaNode : input.getChildNodes()) {
-                Optional<QName> context = getRoutingContext(schemaNode);
-                if (context.isPresent()) {
-                    return new RoutedRpcStrategy(rpc.getQName(), context.get(), schemaNode.getQName());
-                }
+        for (DataSchemaNode schemaNode : rpc.getInput().getChildNodes()) {
+            Optional<QName> context = getRoutingContext(schemaNode);
+            if (context.isPresent()) {
+                return new RoutedRpcStrategy(rpc.getQName(), context.get(), schemaNode.getQName());
             }
         }
         return new GlobalRpcStrategy(rpc.getQName());