org.apache.http.conn.HttpHostConnectException.getMessage()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(9.5k)|赞(0)|评价(0)|浏览(281)

本文整理了Java中org.apache.http.conn.HttpHostConnectException.getMessage()方法的一些代码示例,展示了HttpHostConnectException.getMessage()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HttpHostConnectException.getMessage()方法的具体详情如下:
包路径:org.apache.http.conn.HttpHostConnectException
类名称:HttpHostConnectException
方法名:getMessage

HttpHostConnectException.getMessage介绍

暂无

代码示例

代码示例来源:origin: dreamhead/moco

  1. @Test(expected = ConnectException.class)
  2. public void should_stop_runner_directly() throws IOException {
  3. runner.run();
  4. try {
  5. assertThat(helper.get(root()), is("foo"));
  6. } catch (HttpHostConnectException e) {
  7. fail(e.getMessage());
  8. }
  9. runner.stop();
  10. shutdownMoco(SHUTDOWN_PORT, SHUTDOWN_MOCO_KEY);
  11. }

代码示例来源:origin: dreamhead/moco

  1. @Test(expected = HttpHostConnectException.class)
  2. public void should_stop_runner_via_shutdown_task() throws IOException {
  3. runner.run();
  4. try {
  5. assertThat(helper.get(root()), is("foo"));
  6. } catch (HttpHostConnectException e) {
  7. fail(e.getMessage());
  8. }
  9. ShutdownTask task = new ShutdownTask(SHUTDOWN_MOCO_KEY);
  10. task.run(new String[]{"-s", Integer.toString(SHUTDOWN_PORT)});
  11. waitChangeHappens();
  12. helper.get(root());
  13. }

代码示例来源:origin: dreamhead/moco

  1. @Test(expected = HttpHostConnectException.class)
  2. public void should_shutdown_runner_by_socket() throws IOException {
  3. runner.run();
  4. try {
  5. assertThat(helper.get(root()), is("foo"));
  6. } catch (HttpHostConnectException e) {
  7. fail(e.getMessage());
  8. }
  9. shutdownMoco(SHUTDOWN_PORT, SHUTDOWN_MOCO_KEY);
  10. waitChangeHappens();
  11. helper.get(root());
  12. }

代码示例来源:origin: dreamhead/moco

  1. @Test(expected = HttpHostConnectException.class)
  2. public void should_shutdown_with_shutdown_port() throws IOException {
  3. RunnerFactory factory = new RunnerFactory(SHUTDOWN_MOCO_KEY);
  4. runner = factory.createRunner(httpArgs().withPort(port()).withConfigurationFile("src/test/resources/foo.json").build());
  5. runner.run();
  6. try {
  7. assertThat(helper.get(root()), is("foo"));
  8. } catch (HttpHostConnectException e) {
  9. fail(e.getMessage());
  10. }
  11. ShutdownRunner shutdownRunner = (ShutdownRunner) runner;
  12. int port = shutdownRunner.shutdownPort();
  13. shutdownMoco(port, SHUTDOWN_MOCO_KEY);
  14. waitChangeHappens();
  15. helper.get(root());
  16. }
  17. }

代码示例来源:origin: io.cloudslang.content/cs-http-client

  1. public CloseableHttpResponse execute() {
  2. CloseableHttpResponse response;
  3. try {
  4. response = closeableHttpClient.execute(httpRequestBase, context);
  5. } catch (SocketTimeoutException ste) {
  6. throw new RuntimeException("Socket timeout: " + ste.getMessage(), ste);
  7. } catch (HttpHostConnectException connectEx) {
  8. throw new RuntimeException("Connection error: " + connectEx.getMessage(), connectEx);
  9. } catch (IOException e) {
  10. throw new RuntimeException("Error while executing http request: " + e.getMessage(), e);
  11. }
  12. return response;
  13. }
  14. }

代码示例来源:origin: io.openscore.content/score-http-client

  1. public CloseableHttpResponse execute() {
  2. CloseableHttpResponse response;
  3. try {
  4. response = closeableHttpClient.execute(httpRequestBase, context);
  5. } catch (SocketTimeoutException ste) {
  6. throw new RuntimeException("Socket timeout: " + ste.getMessage(), ste);
  7. } catch (HttpHostConnectException connectEx) {
  8. throw new RuntimeException("Connection error: " + connectEx.getMessage(), connectEx);
  9. } catch (IOException e) {
  10. throw new RuntimeException("Error while executing http request: " + e.getMessage(), e);
  11. }
  12. return response;
  13. }
  14. }

代码示例来源:origin: CloudSlang/cs-actions

  1. public CloseableHttpResponse execute() {
  2. CloseableHttpResponse response;
  3. try {
  4. response = closeableHttpClient.execute(httpRequestBase, context);
  5. } catch (SocketTimeoutException ste) {
  6. throw new RuntimeException("Socket timeout: " + ste.getMessage(), ste);
  7. } catch (HttpHostConnectException connectEx) {
  8. throw new RuntimeException("Connection error: " + connectEx.getMessage(), connectEx);
  9. } catch (IOException e) {
  10. throw new RuntimeException("Error while executing http request: " + e.getMessage(), e);
  11. }
  12. return response;
  13. }
  14. }

代码示例来源:origin: io.cloudslang.content/score-http-client

  1. public CloseableHttpResponse execute() {
  2. CloseableHttpResponse response;
  3. try {
  4. response = closeableHttpClient.execute(httpRequestBase, context);
  5. } catch (SocketTimeoutException ste) {
  6. throw new RuntimeException("Socket timeout: " + ste.getMessage(), ste);
  7. } catch (HttpHostConnectException connectEx) {
  8. throw new RuntimeException("Connection error: " + connectEx.getMessage(), connectEx);
  9. } catch (IOException e) {
  10. throw new RuntimeException("Error while executing http request: " + e.getMessage(), e);
  11. }
  12. return response;
  13. }
  14. }

代码示例来源:origin: elastic/support-diagnostics

  1. protected HttpResponse exec(String url) {
  2. try {
  3. HttpGet httpget = new HttpGet(url);
  4. if (isSecured) {
  5. return client.execute(httpHost, httpget, getLocalContext(httpHost));
  6. } else {
  7. return client.execute(httpHost, httpget);
  8. }
  9. } catch (HttpHostConnectException e) {
  10. logger.log(SystemProperties.DIAG, "Host connection error.", e);
  11. throw new RuntimeException("Host connection error: " + e.getMessage());
  12. } catch (Exception e) {
  13. logger.log(SystemProperties.DIAG, "Query Execution Error", e);
  14. throw new RuntimeException("Query Execution Error: " + e.getMessage());
  15. }
  16. }

代码示例来源:origin: jenkinsci/tfs-plugin

  1. log.warning("ERROR: getApiJson: (url=" + url + ") " + e.getMessage());
  2. return null;
  3. } catch (final Exception e) {

代码示例来源:origin: stackoverflow.com

  1. System.out.println("Host Not Found : "+ e.getMessage())

代码示例来源:origin: org.jenkins-ci.plugins/ec2

  1. } catch (HttpHostConnectException e) {
  2. log.log(Level.SEVERE, "Can't connect to host", e);
  3. throw new WinRMConnectException("Can't connect to host: " + e.getMessage(), e);
  4. } catch (IOException e) {
  5. log.log(Level.SEVERE, "I/O Exception in HTTP POST", e);

代码示例来源:origin: jenkinsci/ec2-plugin

  1. } catch (HttpHostConnectException e) {
  2. log.log(Level.SEVERE, "Can't connect to host", e);
  3. throw new WinRMConnectException("Can't connect to host: " + e.getMessage(), e);
  4. } catch (IOException e) {
  5. log.log(Level.SEVERE, "I/O Exception in HTTP POST", e);

代码示例来源:origin: org.openbaton/sdk

  1. this.bearerToken = "Bearer " + this.token;
  2. } catch (HttpHostConnectException httpHostConnectException) {
  3. throw new SDKException("Host unreachable: " + httpHostConnectException.getMessage());
  4. } catch (Exception e) {
  5. throw new SDKException(e);

代码示例来源:origin: edu.cmu.sei.ams.cloudlet/client-lib

  1. throw new CloudletException(e.getMessage(), e);

代码示例来源:origin: no.difi.oxalis/oxalis-as2

  1. protected TransmissionResponse sendHttpRequest(HttpPost httpPost) throws OxalisTransmissionException {
  2. Span span = tracer.buildSpan("execute").asChildOf(root).start();
  3. try (CloseableHttpClient httpClient = httpClientProvider.get()) {
  4. BasicHttpContext basicHttpContext = new BasicHttpContext();
  5. basicHttpContext.setAttribute(Constants.PARENT_CONTEXT, span.context());
  6. CloseableHttpResponse response = httpClient.execute(httpPost, basicHttpContext);
  7. span.finish();
  8. return handleResponse(response);
  9. } catch (HttpHostConnectException e) {
  10. span.setTag("exception", e.getMessage());
  11. throw new OxalisTransmissionException("Receiving server does not seem to be running.",
  12. transmissionRequest.getEndpoint().getAddress(), e);
  13. } catch (SSLHandshakeException e) {
  14. span.setTag("exception", e.getMessage());
  15. throw new OxalisTransmissionException("Possible invalid SSL Certificate at the other end.",
  16. transmissionRequest.getEndpoint().getAddress(), e);
  17. } catch (IOException e) {
  18. span.setTag("exception", String.valueOf(e.getMessage()));
  19. throw new OxalisTransmissionException(transmissionRequest.getEndpoint().getAddress(), e);
  20. } finally {
  21. span.finish();
  22. }
  23. }

代码示例来源:origin: org.smartrplace.apps/smartrplace-util-proposed

  1. /**
  2. *
  3. * @param path
  4. * @param remotePath
  5. * @param remoteUser
  6. * @param remotePw
  7. * @param serverPortAddress
  8. * @param am
  9. * @return upload result or -1: general exception, -2: host not reachable, -3: internet not reachable
  10. */
  11. public static int sendFile(Path path, String remotePath, String remoteUser, String remotePw, String serverPortAddress, ApplicationManager am) {
  12. try {
  13. return upload(path, remotePath, remoteUser, remotePw, serverPortAddress, am);
  14. } catch (HttpHostConnectException e) {
  15. am.getLogger().warn(e.getMessage());
  16. am.getLogger().debug("Exception detail:", e);
  17. return -2;
  18. } catch (UnknownHostException| NoRouteToHostException e) {
  19. am.getLogger().warn(e.getMessage());
  20. am.getLogger().debug("Exception detail:", e);
  21. return -3;
  22. } catch (KeyManagementException | NoSuchAlgorithmException | IOException e) {
  23. am.getLogger().warn(e.getMessage());
  24. am.getLogger().debug("Exception detail:", e);
  25. return -1;
  26. }
  27. }

代码示例来源:origin: difi/oxalis

  1. protected TransmissionResponse sendHttpRequest(HttpPost httpPost) throws OxalisTransmissionException {
  2. Span span = tracer.buildSpan("execute").asChildOf(root).start();
  3. try (CloseableHttpClient httpClient = httpClientProvider.get()) {
  4. BasicHttpContext basicHttpContext = new BasicHttpContext();
  5. basicHttpContext.setAttribute(Constants.PARENT_CONTEXT, span.context());
  6. CloseableHttpResponse response = httpClient.execute(httpPost, basicHttpContext);
  7. span.finish();
  8. return handleResponse(response);
  9. } catch (SocketTimeoutException e) {
  10. span.setTag("exception", String.valueOf(e.getMessage()));
  11. throw new OxalisTransmissionException("Receiving server has not sent anything back within SOCKET_TIMEOUT", transmissionRequest.getEndpoint().getAddress(), e);
  12. } catch (HttpHostConnectException e) {
  13. span.setTag("exception", e.getMessage());
  14. throw new OxalisTransmissionException("Receiving server does not seem to be running.",
  15. transmissionRequest.getEndpoint().getAddress(), e);
  16. } catch (SSLHandshakeException e) {
  17. span.setTag("exception", e.getMessage());
  18. throw new OxalisTransmissionException("Possible invalid SSL Certificate at the other end.",
  19. transmissionRequest.getEndpoint().getAddress(), e);
  20. } catch (IOException e) {
  21. span.setTag("exception", String.valueOf(e.getMessage()));
  22. throw new OxalisTransmissionException(transmissionRequest.getEndpoint().getAddress(), e);
  23. } finally {
  24. span.finish();
  25. }
  26. }

相关文章

最新文章

更多