ErrorType.RPC, ErrorTag.OPERATION_NOT_SUPPORTED));
}
} else {
- future = invokeRpc(payload.getData(), rpcName, rpcService);
+ future = invokeRpc((ContainerNode)payload.getData(), rpcName, rpcService);
}
} else {
future = invokeRpc(payload.getData(), rpcName, mountPoint);
@VisibleForTesting
static ListenableFuture<? extends DOMRpcResult> invokeRpc(final NormalizedNode data, final QName rpc,
final DOMMountPoint mountPoint) {
- return invokeRpc(data, rpc, mountPoint.getService(DOMRpcService.class).orElseThrow(() -> {
+ return invokeRpc((ContainerNode) data, rpc, mountPoint.getService(DOMRpcService.class).orElseThrow(() -> {
final String errmsg = "RPC service is missing.";
LOG.debug(errmsg);
return new RestconfDocumentedException(errmsg);
* @return {@link DOMRpcResult}
*/
@VisibleForTesting
- static ListenableFuture<? extends DOMRpcResult> invokeRpc(final NormalizedNode data, final QName rpc,
+ static ListenableFuture<? extends DOMRpcResult> invokeRpc(final ContainerNode data, final QName rpc,
final DOMRpcService rpcService) {
return Futures.catching(rpcService.invokeRpc(rpc, nonnullInput(rpc, data)),
DOMRpcException.class,
MoreExecutors.directExecutor());
}
- private static @NonNull NormalizedNode nonnullInput(final QName type, final NormalizedNode input) {
+ private static @NonNull ContainerNode nonnullInput(final QName type, final ContainerNode input) {
return input != null ? input
: ImmutableNodes.containerNode(YangConstants.operationInputQName(type.getModule()));
}