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

Response.getStatusMessage介绍

暂无

代码示例

代码示例来源：origin: prestodb/presto

@Override
  public Optional<QueryStats> handle(Request request, Response response)
  {
    if (response.getStatusCode() == HttpStatus.GONE.code()) {
      return Optional.empty();
    }
    else if (response.getStatusCode() != HttpStatus.OK.code()) {
      throw new RuntimeException("unexpected error code " + response.getStatusCode() + "; reason=" + response.getStatusMessage());
    }
    try {
      JsonNode rootNode = objectMapper.readTree(response.getInputStream());
      JsonNode queryStatsNode = rootNode.get("queryStats");
      if (queryStatsNode == null) {
        return Optional.empty();
      }
      QueryStats queryStats = objectMapper.treeToValue(queryStatsNode, QueryStats.class);
      return Optional.of(queryStats);
    }
    catch (IOException e) {
      throw new UncheckedIOException(e);
    }
  }
}

代码示例来源：origin: prestodb/presto

throw new PageTransportErrorException(format("Expected response code to be 200, but was %s %s:%n%s", response.getStatusCode(), response.getStatusMessage(), body.toString()));

代码示例来源：origin: io.airlift/http-client-experimental

@Override
  public String handle(Request request, Response response)
      throws Exception
  {
    return response.getStatusMessage();
  }
});

代码示例来源：origin: airlift/airlift

public UnexpectedResponseException(Request request, Response response)
{
  this(String.format("%d: %s", response.getStatusCode(), response.getStatusMessage()),
      request,
      response.getStatusCode(),
      response.getStatusMessage(),
      ImmutableListMultimap.copyOf(response.getHeaders()));
}

代码示例来源：origin: airlift/airlift

public UnexpectedResponseException(String message, Request request, Response response)
{
  this(message,
      request,
      response.getStatusCode(),
      response.getStatusMessage(),
      ImmutableListMultimap.copyOf(response.getHeaders()));
}

代码示例来源：origin: com.teradata.airlift/event

@Override
  public Void handle(Request request, Response response)
  {
    int statusCode = response.getStatusCode();
    if (statusCode >= 200 && statusCode <= 299) {
      return null;
    }
    try {
      InputStream inputStream = response.getInputStream();
      String responseBody = CharStreams.toString(new InputStreamReader(inputStream));
      log.debug("Posting event to %s failed: status_code=%d status_line=%s body=%s", request.getUri(), statusCode, response.getStatusMessage(), responseBody);
    }
    catch (IOException bodyError) {
      log.debug("Posting event to %s failed: status_code=%d status_line=%s error=%s",
          request.getUri(),
          statusCode,
          response.getStatusMessage(),
          bodyError.getMessage());
    }
    return null;
  }
}

代码示例来源：origin: airlift/airlift

@Override
public StatusResponse handle(Request request, Response response)
{
  return new StatusResponse(response.getStatusCode(), response.getStatusMessage(), response.getHeaders());
}

代码示例来源：origin: io.airlift/event-experimental

@Override
  public Void handle(Request request, Response response)
  {
    int statusCode = response.getStatusCode();
    if (statusCode >= 200 && statusCode <= 299) {
      return null;
    }
    try {
      InputStream inputStream = response.getInputStream();
      String responseBody = CharStreams.toString(new InputStreamReader(inputStream));
      log.debug("Posting event to %s failed: status_code=%d status_line=%s body=%s", request.getUri(), statusCode, response.getStatusMessage(), responseBody);
    }
    catch (IOException bodyError) {
      log.debug("Posting event to %s failed: status_code=%d status_line=%s error=%s",
          request.getUri(),
          statusCode,
          response.getStatusMessage(),
          bodyError.getMessage());
    }
    return null;
  }
}

代码示例来源：origin: airlift/airlift

@Override
  public Void handle(Request request, Response response)
  {
    int statusCode = response.getStatusCode();
    if (statusCode >= 200 && statusCode <= 299) {
      return null;
    }
    try {
      InputStream inputStream = response.getInputStream();
      String responseBody = CharStreams.toString(new InputStreamReader(inputStream));
      log.debug("Posting event to %s failed: status_code=%d status_line=%s body=%s", request.getUri(), statusCode, response.getStatusMessage(), responseBody);
    }
    catch (IOException bodyError) {
      log.debug("Posting event to %s failed: status_code=%d status_line=%s error=%s",
          request.getUri(),
          statusCode,
          response.getStatusMessage(),
          bodyError.getMessage());
    }
    return null;
  }
}

代码示例来源：origin: prestosql/presto

private static StatusResponse createStatusResponse(Response response)
  {
    return new StatusResponse(response.getStatusCode(), response.getStatusMessage(), response.getHeaders());
  }
}

代码示例来源：origin: com.facebook.presto/presto-raptor

private static StatusResponse createStatusResponse(Response response)
  {
    return new StatusResponse(response.getStatusCode(), response.getStatusMessage(), response.getHeaders());
  }
}

代码示例来源：origin: airlift/airlift

@Override
public StringResponse handle(Request request, Response response)
{
  try {
    String contentType = response.getHeader(CONTENT_TYPE);
    if (contentType != null) {
      MediaType mediaType = MediaType.parse(contentType);
      return new StringResponse(
          response.getStatusCode(),
          response.getStatusMessage(),
          response.getHeaders(),
          new String(ByteStreams.toByteArray(response.getInputStream()), mediaType.charset().or(UTF_8)));
    }
    return new StringResponse(
        response.getStatusCode(),
        response.getStatusMessage(),
        response.getHeaders(),
        new String(ByteStreams.toByteArray(response.getInputStream()), UTF_8));
  }
  catch (IOException e) {
    throw new UncheckedIOException(e);
  }
}

代码示例来源：origin: io.airlift/event

@Override
  public Void handle(Request request, Response response)
  {
    int statusCode = response.getStatusCode();
    if (statusCode >= 200 && statusCode <= 299) {
      return null;
    }
    try {
      InputStream inputStream = response.getInputStream();
      String responseBody = CharStreams.toString(new InputStreamReader(inputStream));
      log.debug("Posting event to %s failed: status_code=%d status_line=%s body=%s", request.getUri(), statusCode, response.getStatusMessage(), responseBody);
    }
    catch (IOException bodyError) {
      log.debug("Posting event to %s failed: status_code=%d status_line=%s error=%s",
          request.getUri(),
          statusCode,
          response.getStatusMessage(),
          bodyError.getMessage());
    }
    return null;
  }
}

代码示例来源：origin: airlift/airlift

@Override
public JsonResponse<T> handle(Request request, Response response)
{
  byte[] bytes = readResponseBytes(response);
  String contentType = response.getHeader(CONTENT_TYPE);
  if ((contentType == null) || !MediaType.parse(contentType).is(MEDIA_TYPE_JSON)) {
    return new JsonResponse<>(response.getStatusCode(), response.getStatusMessage(), response.getHeaders(), bytes);
  }
  return new JsonResponse<>(response.getStatusCode(), response.getStatusMessage(), response.getHeaders(), jsonCodec, bytes);
}

代码示例来源：origin: airlift/airlift

String.format("Expected response code to be %s, but was %d: %s", successfulResponseCodes, response.getStatusCode(), response.getStatusMessage()),
request,
response);

代码示例来源：origin: io.prestosql/presto-main

throw new PageTransportErrorException(format("Expected response code to be 200, but was %s %s:%n%s", response.getStatusCode(), response.getStatusMessage(), body.toString()));

代码示例来源：origin: prestosql/presto

throw new PageTransportErrorException(format("Expected response code to be 200, but was %s %s:%n%s", response.getStatusCode(), response.getStatusMessage(), body.toString()));

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

throw new PageTransportErrorException(format("Expected response code to be 200, but was %s %s: %s", response.getStatusCode(), response.getStatusMessage(), request.getUri()));