2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.remote.rpc.messages;
11 import com.google.common.base.MoreObjects;
12 import com.google.common.base.Preconditions;
13 import java.io.Serializable;
14 import org.opendaylight.controller.cluster.datastore.node.utils.serialization.NormalizedNodeSerializer;
15 import org.opendaylight.controller.md.sal.dom.api.DOMRpcIdentifier;
16 import org.opendaylight.controller.protobuff.messages.common.NormalizedNodeMessages;
17 import org.opendaylight.controller.protobuff.messages.common.NormalizedNodeMessages.Node;
18 import org.opendaylight.yangtools.yang.common.QName;
19 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
25 public class ExecuteRpc implements Serializable {
26 private static final long serialVersionUID = 1128904894827335676L;
28 private final NormalizedNodeMessages.Node inputNormalizedNode;
29 private final QName rpc;
31 private ExecuteRpc(final NormalizedNodeMessages.Node inputNormalizedNode, final QName rpc) {
32 Preconditions.checkNotNull(rpc, "rpc Qname should not be null");
34 this.inputNormalizedNode = inputNormalizedNode;
38 public NormalizedNodeMessages.Node getInputNormalizedNode() {
39 return inputNormalizedNode;
42 public QName getRpc() {
46 public static ExecuteRpc from(final DOMRpcIdentifier rpc, final NormalizedNode<?, ?> input) {
47 final Node serializedInput;
49 serializedInput = NormalizedNodeSerializer.serialize(input);
51 serializedInput = null;
53 return new ExecuteRpc(serializedInput, rpc.getType().getLastComponent());
57 public String toString() {
58 return MoreObjects.toStringHelper(this)
60 .add("normalizedNode", inputNormalizedNode)