import org.opendaylight.netconf.sal.connect.util.MessageCounter;
import org.opendaylight.yangtools.yang.common.QName;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.NodeIdentifier;
-import org.opendaylight.yangtools.yang.data.api.schema.AnyXmlNode;
import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
+import org.opendaylight.yangtools.yang.data.api.schema.DOMSourceAnyxmlNode;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.data.impl.schema.Builders;
-import org.opendaylight.yangtools.yang.model.api.SchemaPath;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
/**
* Transforms anyxml rpcs for schemaless netconf devices.
*/
-public class SchemalessMessageTransformer implements MessageTransformer<NetconfMessage> {
+public class SchemalessMessageTransformer implements MessageTransformer {
// TODO maybe we should move this somewhere else as this
// might be used in applications using schemaless mountpoints
public static final NodeIdentifier SCHEMALESS_NOTIFICATION_PAYLOAD =
+ message + ", cannot find namespace", e);
}
- final AnyXmlNode notificationPayload = Builders.anyXmlBuilder()
+ final DOMSourceAnyxmlNode notificationPayload = Builders.anyXmlBuilder()
.withNodeIdentifier(new NodeIdentifier(notificationNoRev))
.withValue(new DOMSource(stripped.getValue().getDomElement()))
.build();
}
@Override
- public NetconfMessage toRpcRequest(final SchemaPath rpc, final NormalizedNode<?, ?> input) {
- final DOMSource payload = (DOMSource) input.getValue();
+ public NetconfMessage toRpcRequest(final QName rpc, final NormalizedNode input) {
+ final DOMSource payload = (DOMSource) input.body();
wrapPayload((Document) payload.getNode());
- return new NetconfMessage((Document) ((AnyXmlNode) input).getValue().getNode());
+ return new NetconfMessage((Document) ((DOMSourceAnyxmlNode) input).body().getNode());
}
/**
* @return anyxml
*/
@Override
- public DOMRpcResult toRpcResult(final NetconfMessage rpcReply, final SchemaPath rpc) {
+ public DOMRpcResult toRpcResult(final NetconfMessage rpcReply, final QName rpc) {
final Document document = rpcReply.getDocument();
- final AnyXmlNode result;
+ final DOMSourceAnyxmlNode result;
if (BaseRpcSchemalessTransformer.isOkPresent(document)) {
result = null;
} else {