org.eclipse.jetty.client.api.Response.getStatus()方法的使用及代码示例

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

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

Response.getStatus介绍

暂无

代码示例

代码示例来源:origin: spring-projects/spring-framework

@Override
public void onBegin(Response response) {
  if (response.getStatus() != 200) {
    HttpStatus status = HttpStatus.valueOf(response.getStatus());
    response.abort(new HttpServerErrorException(status, "Unexpected XHR receive status"));
  }
}

代码示例来源:origin: konsoletyper/teavm

void send(Response response) {
    if (sent) {
      return;
    }
    sent = true;
    resp.setStatus(response.getStatus());
    for (HttpField field : response.getHeaders()) {
      if (field.getName().toLowerCase().equals("location")) {
        String value = field.getValue();
        if (value.startsWith(proxyUrl)) {
          String relLocation = value.substring(proxyUrl.length());
          resp.addHeader(field.getName(), "http://localhost:" + port + proxyPath + relLocation);
          continue;
        }
      }
      resp.addHeader(field.getName(), field.getValue());
    }
  }
}

代码示例来源:origin: apache/incubator-druid

"success",
success
&& result.getResponse().getStatus() == Status.OK.getStatusCode()

代码示例来源:origin: jersey/jersey

private static ClientResponse translateResponse(final ClientRequest jerseyRequest,
                        final org.eclipse.jetty.client.api.Response jettyResponse,
                        final NonBlockingInputStream entityStream) {
  final ClientResponse jerseyResponse = new ClientResponse(Statuses.from(jettyResponse.getStatus()), jerseyRequest);
  processResponseHeaders(jettyResponse.getHeaders(), jerseyResponse);
  jerseyResponse.setEntityStream(entityStream);
  return jerseyResponse;
}

代码示例来源:origin: resteasy/Resteasy

@Override
public void onHeaders(Response response) {
 cr = new JettyClientResponse(invocation.getClientConfiguration(), stream, () -> {
   if (!completing.get()) {
    future.cancel(true);
   }
 });
 cr.setProperties(invocation.getMutableProperties());
 cr.setStatus(response.getStatus());
 cr.setHeaders(extract(response.getHeaders()));
 if (!buffered) {
   complete();
 }
}

代码示例来源:origin: org.eclipse.jetty/jetty-client

@Override
public boolean accept(Request request, Response response)
{
  return response.getStatus() == HttpStatus.UNAUTHORIZED_401;
}

代码示例来源:origin: org.eclipse.jetty/jetty-client

@Override
public int getStatus()
{
  return response.getStatus();
}

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

@Override
public int getStatusCode()
{
  return response.getStatus();
}

代码示例来源:origin: com.proofpoint.platform/http-client

@Override
public int getStatusCode()
{
  return response.getStatus();
}

代码示例来源:origin: com.cisco.oss.foundation/http-client-jetty

@Override
public boolean isSuccess() {
  boolean isSuccess = false;
  int status = httpResponse.getStatus() >= 0 ? httpResponse.getStatus() : 0;
  isSuccess = status / 100 == 2;
  return isSuccess;
}

代码示例来源:origin: org.eclipse.jetty/jetty-client

@Override
public boolean accept(Request request, Response response)
{
  return response.getStatus() == HttpStatus.PROXY_AUTHENTICATION_REQUIRED_407;
}

代码示例来源:origin: census-instrumentation/opencensus-java

@Override
public int getStatusCode(@Nullable Response response) {
 if (response != null) {
  return response.getStatus();
 }
 return 0;
}

代码示例来源:origin: org.eclipse.jetty/jetty-proxy

@Override
public void onBegin(Response serverResponse)
{
  response = serverResponse;
  proxyResponse.setStatus(serverResponse.getStatus());
}

代码示例来源:origin: blazegraph/database

/**
 * The http status code.
 */
public int getStatus() throws IOException {
  ensureResponse();
  
  return m_response.getStatus();
}

代码示例来源:origin: isucon/isucon5-qualify

public void isStatus(int status) {
 if (response.getStatus() != status) {
  addViolation(String.format("パス '%s' へのレスポンスコード %d が期待されていましたが %d でした", response.getRequest().getPath(), status, response.getStatus()));
 }
}

代码示例来源:origin: org.springframework/spring-websocket

@Override
public void onBegin(Response response) {
  if (response.getStatus() != 200) {
    HttpStatus status = HttpStatus.valueOf(response.getStatus());
    response.abort(new HttpServerErrorException(status, "Unexpected XHR receive status"));
  }
}

代码示例来源:origin: org.ligoj.bootstrap/bootstrap-web

@Override
protected void onServerResponseHeaders(final HttpServletRequest request, final HttpServletResponse response, final Response proxyResponse) {
  if (needPlainPageErrorStatus(request, proxyResponse.getStatus()) == 0) {
    super.onServerResponseHeaders(request, response, proxyResponse);
  } else {
    // Standard 404 page
    response.addHeader("Content-Type", "text/html");
  }
  response.addHeader("Access-Control-Allow-Origin", "*");
}

代码示例来源:origin: org.eclipse.jetty/jetty-client

@Override
public boolean accept(Request request, Response response)
{
  boolean is100 = response.getStatus() == HttpStatus.CONTINUE_100;
  boolean expect100 = request.getHeaders().contains(HttpHeader.EXPECT, HttpHeaderValue.CONTINUE.asString());
  boolean handled100 = request.getAttributes().containsKey(ATTRIBUTE);
  return (is100 || expect100) && !handled100;
}

代码示例来源:origin: org.glassfish.jersey.connectors/jersey-jetty-connector

private static ClientResponse translateResponse(final ClientRequest jerseyRequest,
                        final org.eclipse.jetty.client.api.Response jettyResponse,
                        final NonBlockingInputStream entityStream) {
  final ClientResponse jerseyResponse = new ClientResponse(Statuses.from(jettyResponse.getStatus()), jerseyRequest);
  processResponseHeaders(jettyResponse.getHeaders(), jerseyResponse);
  jerseyResponse.setEntityStream(entityStream);
  return jerseyResponse;
}

代码示例来源:origin: allegro/hermes

SingleMessageSendingResult(Result result) {
  this.failure = result.getFailure();
  if (result.getResponse() != null) {
    initializeForStatusCode(result.getResponse().getStatus());
    if (isStatusCodeServiceUnavailable()) {
      initializeRetryAfterMillis(result);
    }
  }
  this.loggable = !isTimeout() && !hasHttpAnswer();
  this.requestUri = Optional.ofNullable(result.getRequest().getURI());
}

相关文章