* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.netconf.test.tool.rpchandler;
import java.util.Optional;
-import org.opendaylight.controller.config.util.xml.DocumentedException;
-import org.opendaylight.controller.config.util.xml.XmlElement;
-import org.opendaylight.controller.config.util.xml.XmlUtil;
+import org.opendaylight.netconf.api.DocumentedException;
+import org.opendaylight.netconf.api.xml.XmlElement;
import org.opendaylight.netconf.api.xml.XmlNetconfConstants;
-import org.opendaylight.netconf.mapping.api.HandlingPriority;
-import org.opendaylight.netconf.mapping.api.NetconfOperation;
-import org.opendaylight.netconf.mapping.api.NetconfOperationChainedExecution;
+import org.opendaylight.netconf.api.xml.XmlUtil;
+import org.opendaylight.netconf.server.api.operations.HandlingPriority;
+import org.opendaylight.netconf.server.api.operations.NetconfOperation;
+import org.opendaylight.netconf.server.api.operations.NetconfOperationChainedExecution;
+import org.opendaylight.yangtools.yang.common.ErrorSeverity;
+import org.opendaylight.yangtools.yang.common.ErrorTag;
+import org.opendaylight.yangtools.yang.common.ErrorType;
import org.w3c.dom.Document;
/**
* {@link NetconfOperation} which is able to handle it.
*/
class SettableRpc implements NetconfOperation {
-
private final RpcHandler rpcHandler;
- SettableRpc(RpcHandler rpcHandler) {
+ SettableRpc(final RpcHandler rpcHandler) {
this.rpcHandler = rpcHandler;
}
@Override
- public HandlingPriority canHandle(final Document message) throws DocumentedException {
+ public HandlingPriority canHandle(final Document message) {
return HandlingPriority.HANDLE_WITH_DEFAULT_PRIORITY.increasePriority(1000);
}
final String msgId = requestElement.getAttribute(XmlNetconfConstants.MESSAGE_ID);
final Optional<Document> response = rpcHandler.getResponse(rpcElement);
if (response.isPresent()) {
- final Document document = response.get();
+ final Document document = response.orElseThrow();
checkForError(document);
document.getDocumentElement().setAttribute(XmlNetconfConstants.MESSAGE_ID, msgId);
return document;
} else if (subsequentOperation.isExecutionTermination()) {
throw new DocumentedException("Mapping not found " + XmlUtil.toString(requestMessage),
- DocumentedException.ErrorType.APPLICATION, DocumentedException.ErrorTag.OPERATION_NOT_SUPPORTED,
- DocumentedException.ErrorSeverity.ERROR);
+ ErrorType.APPLICATION, ErrorTag.OPERATION_NOT_SUPPORTED, ErrorSeverity.ERROR);
} else {
return subsequentOperation.execute(requestMessage);
}
}
- private void checkForError(final Document document) throws DocumentedException {
+ private static void checkForError(final Document document) throws DocumentedException {
final XmlElement rpcReply = XmlElement.fromDomDocument(document);
if (rpcReply.getOnlyChildElementOptionally("rpc-error").isPresent()) {
throw DocumentedException.fromXMLDocument(document);
}
}
-
}