com.atlassian.sal.api.net.Request类的使用及代码示例

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

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

Request介绍

暂无

代码示例

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

  1. public String execute()
  2.     throws ResponseException
  3. {
  4.   return request.execute();
  5. }

代码示例来源：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.plugins.rest/atlassian-rest-module

  1. public JerseyRequest addBasicAuthentication(String hostname, String username, String password) {
  2.   delegateRequest.addBasicAuthentication(hostname, username, password);
  3.   return this;
  4. }

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

  1. private static Request<?, ?> createDefaultRequest(RequestFactoryAdapter requestFactoryAdapter, MethodType methodType, String url) throws CredentialsRequiredException {
  2.   return requestFactoryAdapter.createRequest(methodType, url)
  3.       .setFollowRedirects(true)
  4.       .addHeader(OVERRIDE_HEADER_NAME, OVERRIDE_HEADER_VALUE);
  5. }

代码示例来源：origin: com.atlassian.jira.plugins/jira-dvcs-connector-api

  1. @Override
  2. public void addAuthentication(Request<?, ?> request, String url) {
  3.   request.addHeader("Authorization", "token " + accessToken);
  4.   String separator = url.contains("?") ? "&" : "?";
  5.   url += separator + "access_token=" + getAccessToken();
  6.   request.setUrl(url);
  7. }

代码示例来源：origin: com.atlassian.studio/studio-theme-jira-plugin

  1. @Override
  2. protected String doExecute() throws Exception
  3. {
  4.   String crucibleUrl = getCrucibleUrl();
  5.   if (crucibleUrl == null)
  6.   {
  7.     return SUCCESS;
  8.   }
  9.   Request<?> request = requestFactory.createRequest(Request.MethodType.PUT,
  10.     crucibleUrl + CRUCIBLE_METRICS_REST_ENDPOINT);
  11.   request.addTrustedTokenAuthentication(themeProperties.getSystemAdministrator());
  12.   request.setRequestBody(metrics);
  13.   try
  14.   {
  15.     metrics = request.execute();
  16.   }
  17.   catch (ResponseException re)
  18.   {
  19.     addErrorMessage(getText("crucible.admin.error.response"));
  20.     log.error("Error communicating with Crucible", re);
  21.   }
  22.   return getRedirect("EditMetrics!Default.jspa?message=crucible.admin.info.metrics.updated");
  23. }

代码示例来源：origin: com.atlassian.studio/studio-jira-fisheye-plugin

  1. request.addRequestParameters("url", baseUrl + JIRA_NOTIFICIATION_URL);
  2. request.addTrustedTokenAuthentication();
  3. try
  4.   request.execute();

代码示例来源：origin: com.atlassian.studio/studio-theme-jira-plugin

  1. @Override
  2. public String doDefault() throws Exception
  3. {
  4.   String crucibleUrl = getCrucibleUrl();
  5.   if (crucibleUrl == null)
  6.   {
  7.     return SUCCESS;
  8.   }
  9.   Request<?> request = requestFactory.createRequest(Request.MethodType.GET,
  10.     crucibleUrl + CRUCIBLE_METRICS_REST_ENDPOINT);
  11.   request.addTrustedTokenAuthentication(themeProperties.getSystemAdministrator());
  12.   try
  13.   {
  14.     metrics = request.execute();
  15.   }
  16.   catch (ResponseException re)
  17.   {
  18.     addErrorMessage(getText("crucible.admin.error.response"));
  19.     log.error("Error communicating with Crucible", re);
  20.   }
  21.   return SUCCESS;
  22. }

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

  1. .setConnectionTimeout(CONNECTION_TIMEOUT)
  2. .setSoTimeout(CONNECTION_TIMEOUT)
  3. .setFollowRedirects(false)
  4. .execute(new ResponseHandler()

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

  1. request.addBasicAuthentication("", getFisheyeAdminPassword());
  2. request.execute(responseHandler);

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

  1. public Iterable<ExternalActivityItem> getItems(ApplicationLink appLink, ExternalActivityItemSearchParams params) throws Exception
  2.   {
  3.     final String uri = remoteStreamsFeedUriBuilder.buildUri(appLink, params).toASCIIString();
  5.     try
  6.     {
  7.       final Request<?, ?> request = appLink.createAuthenticatedRequestFactory().createRequest(Request.MethodType.GET, uri);
  8.       request.setConnectionTimeout(CONNECTION_TIMEOUT);
  9.       request.setSoTimeout(SO_TIMEOUT);
  10.       return itemFactory.getItems(request.execute());
  11.     }
  12.     catch (Exception e)
  13.     {
  14.       log.warn("Cannot fetch remote feed from: " + uri);
  15.       throw e;
  16.     }
  17.   }
  18. }

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

  1. private TokenAndSecret requestToken(String url, Request signedRequest)
  2.     throws ResponseException {
  3.   final com.atlassian.sal.api.net.Request tokenRequest = requestFactory.createRequest(com.atlassian.sal.api.net.Request.MethodType.POST, url);
  4.   tokenRequest.addRequestParameters(parameterToStringArray(signedRequest.getParameters()));
  5.   tokenRequest.setFollowRedirects(false);
  6.   tokenRequest.execute(responseHandler);
  7.   final Map<String, String> oAuthParameterMap = oauthParametersHolder.get();

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

  1. @Test
  2. public void testCanSendMultipartPutRequest() throws Exception {
  3.   Server server = new Server(0);
  4.   ServletHandler handler = new ServletHandler();
  5.   handler.addServletWithMapping(SetFilesServlet.class, "/*");
  6.   server.setHandler(handler);
  7.   try {
  8.     // start jetty.
  9.     server.start();
  10.     // now, make a request.
  11.     Request<?, ?> request = requestFactory.createRequest(Request.MethodType.PUT, "http://localhost:" + getActivePort(server));
  12.     request.setFiles(Collections.singletonList(new RequestFilePart(testFile, "testFile")));
  13.     request.execute(new ResponseHandler() {
  14.       public void handle(final Response response) throws ResponseException {
  15.         assertTrue(response.isSuccessful());
  16.       }
  17.     });
  18.   } finally {
  19.     server.stop();
  20.   }
  21. }

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

  1. request.setRequestBody(data, "text/xml");
  2. if (log.isDebugEnabled())
  3. try
  4.   request.execute();

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

  1. .toString());
  2. createLinkBackRequest.setEntity(linkBack);
  3.   createLinkBackRequest.execute(new ResponseHandler<Response>() {
  4.     public void handle(final Response createLinkBackResponse) throws ResponseException {
  5.       if (createLinkBackResponse.getStatusCode() == 201) {

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

  1. /**
  2.  * Fetches consumer information from a remote applinked application, assuming it is running the OAuth plugin.
  3.  *
  4.  * @param applicationLink link to fetch the information from
  5.  * @return Consumer object representing the linked application
  6.  * @throws ResponseException if the fetch fails for any reason
  7.  */
  8. @Nonnull
  9. public static Consumer fetchConsumerInformation(@Nonnull ApplicationLink applicationLink) throws ResponseException {
  10.   final Request<?, ?> request = Anonymous.createAnonymousRequest(applicationLink, Request.MethodType.GET,
  11.       Uris.uncheckedConcatenate(applicationLink.getRpcUrl(), CONSUMER_INFO_PATH).toString());
  12.   request.setHeader("Accept", "application/xml");
  13.   final ConsumerInformationResponseHandler handler = new ConsumerInformationResponseHandler();
  14.   request.execute(handler);
  15.   return handler.getConsumer();
  16. }

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

  1. try {
  2.   final Request<Request<?, Response>, Response> request = requestFactory.createRequest(action, autoConfigUrl.toString());
  3.   request.addHeader(XsrfProtectedServlet.OVERRIDE_HEADER_NAME, XsrfProtectedServlet.OVERRIDE_HEADER_VALUE);
  4.   request.execute(new ResponseHandler<Response>() {
  5.     public void handle(final Response response) throws ResponseException {
  6.       if (response.isSuccessful()) {

代码示例来源：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.sal/sal-ctk-plugin

  1. public void execute(final CtkTestResults results) throws ResponseException
  2.   {
  3.     results.assertTrue("RequestFactory must be injectable", requestFactory != null);
  5.     Request<?, ?> request = requestFactory.createRequest(Request.MethodType.GET, "http://google.com");
  7.     request.execute(new ResponseHandler()
  8.     {
  9.       public void handle(final Response response) throws ResponseException
  10.       {
  11.         passed = response.getResponseBodyAsString().contains("Google");
  12.       }
  13.     });
  14.     results.assertTrue("Should be able to call http://google.com and get result that contains 'google'", passed);
  16.     request = requestFactory.createRequest(Request.MethodType.GET, "http://demo.jira.com");
  17.     request.addSeraphAuthentication("admin", "admin");
  19.     request.execute(new ResponseHandler()
  20.     {
  21.       public void handle(final Response response) throws ResponseException
  22.       {
  23.         passed = response.getResponseBodyAsString().contains("Joe Administrator");
  24.       }
  25.     });
  26.     results.assertTrueOrWarn("Should be able to call http://demo.jira.com and log in using seraph authentication", passed);
  27.   }
  28. }

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

  1. request.setHeader("X-Atlassian-Token", "no-check");
  2. request.setHeader("X-Forwarded-For", xForward != null ? xForward : req.getRemoteAddr());
  3.   if (ctHeader != null)
  4.     request.setHeader("Content-Type", ctHeader);
  5.       params.add(req.getParameter(name));
  6.     request.addRequestParameters((String[]) params.toArray(new String[params.size()]));
  7.     request.setRequestBody(str);

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

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