com.atlassian.sal.api.net.Request.executeAndReturn()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(270)

本文整理了Java中com.atlassian.sal.api.net.Request.executeAndReturn方法的一些代码示例，展示了Request.executeAndReturn的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Request.executeAndReturn方法的具体详情如下：
包路径：com.atlassian.sal.api.net.Request
类名称：Request
方法名：executeAndReturn

Request.executeAndReturn介绍

暂无

代码示例

代码示例来源：origin: com.atlassian.applinks/applinks-plugin-core

  1. @Override
  2. public <RET> RET executeAndReturn(final ReturningResponseHandler<? super Response, RET> responseHandler)
  3.     throws ResponseException
  4. {
  5.   return (RET) request.executeAndReturn(responseHandler);
  6. }

代码示例来源：origin: com.atlassian.applinks/applinks-plugin-core

  1. public <R> R execute(final ApplicationLinkResponseHandler<R> applicationLinkResponseHandler)
  2.     throws ResponseException
  3. {
  4.   return (R) request.executeAndReturn(applicationLinkResponseHandler);
  5. }

代码示例来源：origin: com.atlassian.applinks/applinks-common

  1. @Override
  2. public <RET> RET executeAndReturn(final ReturningResponseHandler<? super Response, RET> responseHandler)
  3.     throws ResponseException {
  4.   return (RET) request.executeAndReturn(responseHandler);
  5. }

代码示例来源：origin: com.atlassian.applinks/applinks-common

  1. public <R> R execute(final ApplicationLinkResponseHandler<R> applicationLinkResponseHandler)
  2.     throws ResponseException {
  3.   return (R) request.executeAndReturn(applicationLinkResponseHandler);
  4. }

代码示例来源：origin: com.atlassian.plugins.rest/atlassian-rest-module

  1. @Override
  2. public <RET> RET executeAndReturn(final ReturningResponseHandler<? super JerseyResponse, RET> responseHandler) throws ResponseException {
  3.   marshallEntity();
  4.   final Object result = delegateRequest.executeAndReturn(new ReturningResponseHandler<Response, RET>() {
  5.     public RET handle(final Response response) throws ResponseException {
  6.       JerseyResponse res = new JerseyResponse(response, jerseyEntityHandler, plugin);
  7.       return responseHandler.handle(res);
  8.     }
  9.   });
  10.   return (RET) result;
  11. }

代码示例来源：origin: com.atlassian.refapp/platform-ctk-plugin

  1. protected <R> R get(URI uri, final Class<R> resultClass)
  2.     throws ResponseException {
  3.   Request request = createRequestWithBasicAuthentication(uri);
  4.   Object result = request.executeAndReturn(
  5.       new ReturningResponseHandler() {
  6.         public Object handle(Response response) throws ResponseException {
  7.           return response.getEntity(resultClass);
  8.         }
  9.       }
  10.   );
  11.   return (R) result;
  12. }

代码示例来源：origin: com.atlassian.hipchat.plugins/hipchat-core-plugin

  1. @GET
  2. public final Response get(@Context UriInfo uriInfo, @Context HttpHeaders headers, @PathParam("path") String path)
  3. {
  4.   final URI uri = buildUri(path, uriInfo.getQueryParameters());
  5.   logger.info("Getting URI: '{}'", uri);
  6.   final Request<?, com.atlassian.sal.api.net.Response> salRequest = buildSalRequest(uri, headers.getRequestHeaders());
  7.   try
  8.   {
  9.     return salRequest.executeAndReturn(new JaxRsResponseHandler());
  10.   }
  11.   catch (ResponseException e)
  12.   {
  13.     return Response.serverError().entity(e.getMessage()).build();
  14.   }
  15. }

代码示例来源：origin: com.marvelution.atlassian.suite.plugins/atlassian-sonarqube-common

  1. @Override
  2. public ApplicationStatus getStatus(URI url) {
  3.   try {
  4.     LOGGER.debug("Querying " + url + " for its online status.");
  5.     final Request<Request<?, Response>, Response> request =
  6.         requestFactory.createRequest(Request.MethodType.GET, url.toString());
  7.     request.setConnectionTimeout(CONNECTION_TIMEOUT).setSoTimeout(CONNECTION_TIMEOUT);
  8.     return request.executeAndReturn(new ReturningResponseHandler<Response, ApplicationStatus>() {
  9.       @Override
  10.       public ApplicationStatus handle(final Response response) throws ResponseException {
  11.         return response.isSuccessful() || (response.getStatusCode() == HttpStatus.SC_FORBIDDEN) ?
  12.             ApplicationStatus.AVAILABLE : ApplicationStatus.UNAVAILABLE;
  13.       }
  14.     });
  15.   } catch (ResponseException re) {
  16.     return ApplicationStatus.UNAVAILABLE;
  17.   }
  18. }

代码示例来源：origin: com.marvelution.jira.plugins/jira-jenkins-plugin

  1. @Override
  2. public ApplicationStatus getStatus(URI url) {
  3.   try {
  4.     LOGGER.debug("Querying " + url + " for its online status.");
  5.     final Request<Request<?, Response>, Response> request = requestFactory.createRequest(Request.MethodType.GET, url.toString());
  6.     request.setConnectionTimeout(CONNECTION_TIMEOUT).setSoTimeout(CONNECTION_TIMEOUT);
  7.     return request.executeAndReturn(new ReturningResponseHandler<Response, ApplicationStatus>() {
  8.       @Override
  9.       public ApplicationStatus handle(final Response response) throws ResponseException {
  10.         return response.isSuccessful() || (response.getStatusCode() == HttpStatus.SC_FORBIDDEN) || (response.getStatusCode()
  11.             == HttpStatus.SC_UNAUTHORIZED) ? ApplicationStatus.AVAILABLE : ApplicationStatus.UNAVAILABLE;
  12.       }
  13.     });
  14.   } catch (ResponseException re) {
  15.     return ApplicationStatus.UNAVAILABLE;
  16.   }
  17. }

代码示例来源：origin: com.atlassian.applinks/applinks-common

  1. @SuppressWarnings("unchecked")
  2. private void remoteDisableUsingAutoConfigurationServlet(ApplicationLink applink, RequestFactoryAdapter requestFactoryAdapter)
  3.     throws AuthenticationConfigurationException {
  4.   try {
  5.     createDefaultRequest(requestFactoryAdapter, MethodType.DELETE, getAutoConfigServletUrl(applink)).executeAndReturn(LoggingReturningResponseHandler.INSTANCE);
  6.   } catch (ResponseException | CredentialsRequiredException e) {
  7.     throw new AuthenticationConfigurationException(e);
  8.   }
  9. }

代码示例来源：origin: com.atlassian.jira/jira-issue-link-remote-jira-plugin

  1. public RemoteResponse<RemoteJiraIssue> getIssue(final String baseUri, final String issueIdOrKey, final RestVersion restVersion) throws CredentialsRequiredException, ResponseException
  2. {
  3.   final Request<?, Response> request = createGetIssueRequest(baseUri, issueIdOrKey, restVersion);
  4.   final ResponseToIssueConverter jsonConverter = new ResponseToIssueConverter(baseUri, restVersion);
  5.   return request.executeAndReturn(new RestResponseHandler<RemoteJiraIssue>(jsonConverter, restVersion));
  6. }

代码示例来源：origin: com.atlassian.applinks/applinks-plugin-core

  1. /**
  2.    * Does a GET on the baseurl and expects a 200 status code.
  3.    *
  4.    * @param url   baseUrl of the peer.
  5.    * @return
  6.    */
  7.   public ApplicationStatus getStatus(final URI url)
  8.   {
  9.     try
  10.     {
  11.       LOG.debug("Querying " + url + " for its online status.");
  12.       final Request<Request<?, Response>,Response> request = requestFactory
  13.         .createRequest(Request.MethodType.GET, url.toString());
  14.       request.setConnectionTimeout(CONNECTION_TIMEOUT).setSoTimeout(CONNECTION_TIMEOUT);
  15.       return request.executeAndReturn(new ReturningResponseHandler<Response,ApplicationStatus>()
  16.         {
  17.           public ApplicationStatus handle(final Response response) throws ResponseException
  18.           {
  19.             return response.isSuccessful() ?
  20.                 ApplicationStatus.AVAILABLE :
  21.                 ApplicationStatus.UNAVAILABLE;
  22.           }
  23.         });
  24.     }
  25.     catch (ResponseException re)
  26.     {
  27.       return ApplicationStatus.UNAVAILABLE;
  28.     }
  29.   }
  30. }

代码示例来源：origin: com.atlassian.applinks/applinks-plugin

  1. public boolean isAdminUserInRemoteApplication(final URI url, final String username, final String password)
  2.     throws ResponseException {
  3.   final URI uri = Uris.uncheckedConcatenate(url, RestUtil.REST_APPLINKS_URL);
  4.   final AuthenticationResource restUrl = restUrlBuilder.getUrlFor(uri, AuthenticationResource.class);
  5.   return requestFactory
  6.       .createRequest(Request.MethodType.GET,
  7.           restUrl.getIsAdminUser().toString())
  8.       .addBasicAuthentication(url.getHost(), username, password)
  9.       .executeAndReturn(new ReturningResponseHandler<Response, Boolean>() {
  10.         public Boolean handle(final Response restResponse) throws ResponseException {
  11.           return restResponse.isSuccessful();
  12.         }
  13.       });
  14. }

代码示例来源：origin: com.atlassian.applinks/applinks-common

  1. /**
  2.    * Does a GET on the baseurl and expects a 200 status code.
  3.    *
  4.    * @param url baseUrl of the peer.
  5.    * @return ApplicationStatus for the url
  6.    */
  7.   public ApplicationStatus getStatus(final URI url) {
  8.     try {
  9.       LOG.debug("Querying " + url + " for its online status.");
  10.       final Request<Request<?, Response>, Response> request = requestFactory
  11.           .createRequest(Request.MethodType.GET, url.toString());
  12.       request.setConnectionTimeout(CONNECTION_TIMEOUT).setSoTimeout(CONNECTION_TIMEOUT);
  13.       return request.executeAndReturn(response -> response.isSuccessful() ?
  14.           ApplicationStatus.AVAILABLE :
  15.           ApplicationStatus.UNAVAILABLE);
  16.     } catch (ResponseException re) {
  17.       return ApplicationStatus.UNAVAILABLE;
  18.     }
  19.   }
  20. }

代码示例来源：origin: com.atlassian.applinks/applinks-common

  1. @SuppressWarnings("unchecked")
  2. private void setRemoteStatus(ApplinkOAuthStatus status, ApplicationLink applink, RequestFactoryAdapter requestFactoryAdapter)
  3.     throws ResponseException, CredentialsRequiredException {
  4.   createDefaultJsonRequest(requestFactoryAdapter, MethodType.PUT, getStatusResourceUrl(applink))
  5.       .setEntity(new RestApplinkOAuthStatus(status))
  6.       .executeAndReturn(LoggingReturningResponseHandler.INSTANCE);
  7. }

代码示例来源：origin: com.atlassian.applinks/applinks-common

  1. private void remoteEnableUsingAuthenticationApi(OAuthConfig incoming,
  2.                         OAuthConfig outgoing,
  3.                         ApplicationLink applink,
  4.                         RequestFactoryAdapter requestFactoryAdapter,
  5.                         RemoteApplicationCapabilities capabilities)
  6.     throws AuthenticationConfigurationException {
  7.   try {
  8.     // enable consumer (incoming)
  9.     if (incoming.isEnabled()) {
  10.       createDefaultJsonRequest(requestFactoryAdapter, MethodType.PUT, getAuthenticationConsumerResourceUrl(applink, capabilities))
  11.           .setEntity(getRestConsumer(incoming))
  12.           .executeAndReturn(LoggingReturningResponseHandler.INSTANCE);
  13.     }
  14.     if (outgoing.isEnabled()) {
  15.       String authenticationProviderUrl = getAuthenticationProviderResourceUrl(applink);
  16.       // enable providers (outgoing)
  17.       for (Class<? extends AuthenticationProvider> providerClass : getProviders(outgoing)) {
  18.         createDefaultJsonRequest(requestFactoryAdapter, MethodType.PUT, authenticationProviderUrl)
  19.             .setEntity(new RestAuthenticationProvider(providerClass))
  20.             .executeAndReturn(LoggingReturningResponseHandler.INSTANCE);
  21.       }
  22.     }
  23.   } catch (ResponseException | CredentialsRequiredException e) {
  24.     throw new AuthenticationConfigurationException(e);
  25.   }
  26. }

代码示例来源：origin: com.atlassian.applinks/applinks-plugin

  1. errorListEntity = request
  2.     .setEntity(linkBackToMyself)
  3.     .executeAndReturn(new ReturningResponseHandler<Response, ErrorListEntity>() {
  4.       public ErrorListEntity handle(final Response response) throws ResponseException {

内容来源于网络，如有侵权，请联系作者删除！

request

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com