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