import java.io.ObjectOutput;
import org.eclipse.jdt.annotation.NonNull;
import org.eclipse.jdt.annotation.Nullable;
-import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeDataInput;
import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeDataOutput;
import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeInputOutput;
import org.opendaylight.mdsal.dom.api.DOMRpcIdentifier;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
+import org.opendaylight.yangtools.yang.data.codec.binfmt.NormalizedNodeDataInput;
import org.opendaylight.yangtools.yang.model.api.SchemaPath;
public final class ExecuteRpc extends AbstractExecute<@Nullable NormalizedNode<?, ?>> {
@Override
public void readExternal(final ObjectInput in) throws IOException {
- final NormalizedNodeDataInput stream = NormalizedNodeInputOutput.newDataInput(in);
+ final NormalizedNodeDataInput stream = NormalizedNodeDataInput.newDataInput(in);
final SchemaPath type = SchemaPath.ROOT.createChild(stream.readQName());
final NormalizedNode<?, ?> input = stream.readOptionalNormalizedNode().orElse(null);
executeRpc = new ExecuteRpc(type, input);