本文整理了Java中io.airlift.http.client.Response.getStatusMessage
方法的一些代码示例,展示了Response.getStatusMessage
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response.getStatusMessage
方法的具体详情如下:
包路径:io.airlift.http.client.Response
类名称: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()));
内容来源于网络,如有侵权,请联系作者删除!