- public RpcResult<CompositeNode> invokeRpc( CompositeNode rpcRequest ) throws ResponseException {
- ListenableFuture<RpcResult<CompositeNode>> rpcFuture =
- mountPoint.rpc( getRpcDefinition().getQName(), rpcRequest);
- try {
- return rpcFuture.get();
- } catch (InterruptedException | ExecutionException e) {
- throw new ResponseException(Status.INTERNAL_SERVER_ERROR,
- e.getCause().getMessage() );
+ protected Future<RpcResult<CompositeNode>> invokeRpcUnchecked(CompositeNode rpcRequest) {
+ Optional<RpcProvisionRegistry> service = mountPoint.getService(RpcProvisionRegistry.class);
+ if (service.isPresent()) {
+ return service.get().invokeRpc(getRpcDefinition().getQName(), rpcRequest);