javax.ws.rs.container.ContainerResponseContext.getStatus()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(11.4k)|赞(0)|评价(0)|浏览(105)

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

ContainerResponseContext.getStatus介绍

[英]Get the status code associated with the response.
[中]获取与响应关联的状态代码。

代码示例

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

@Override
 public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext)
   throws IOException {
  final String method = requestContext.getMethod();
  final String uri = requestContext.getUriInfo().getRequestUri().toString();
  final int respStatus = responseContext.getStatus();
  final String reasonPhrase = responseContext.getStatusInfo().getReasonPhrase();
  final String srcIpAddr = request.get().getRemoteAddr();
  final String contentType = requestContext.getHeaderString(HttpHeaders.CONTENT_TYPE);
  LOGGER.info("Handled request from {} {} {}, content-type {} status code {} {}", srcIpAddr, method, uri, contentType,
    respStatus, reasonPhrase);
 }
}

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

@Override
public void filter(final ContainerRequestContext request,
    final ContainerResponseContext response) throws IOException {
  String id = request.getHeaderString(REQUEST_ID);
  if (Strings.isNullOrEmpty(id)) {
    id = generateRandomUuid().toString();
  }
  logger.trace("method={} path={} request_id={} status={} length={}",
      request.getMethod(), request.getUriInfo().getPath(), id,
      response.getStatus(), response.getLength());
  response.getHeaders().putSingle(REQUEST_ID, id);
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
  // we have already added the necessary headers for OPTIONS requests below
  if ("options".equalsIgnoreCase(requestContext.getRequest().getMethod())) {
    if(Response.Status.Family.familyOf(responseContext.getStatus()) == Response.Status.Family.SUCCESSFUL) {
      return;
    }
    responseContext.setStatus(Response.Status.NO_CONTENT.getStatusCode());
    responseContext.setEntity("");
  }
  String origin = requestContext.getHeaders().getFirst("Origin");
  if (origin != null && !origin.isEmpty()) {
    responseContext.getHeaders().add("Access-Control-Allow-Origin", origin);
    responseContext.getHeaders().add("Access-Control-Allow-Credentials", true);
    responseContext.getHeaders().add("Access-Control-Allow-Headers", "Authorization, Content-Type, X-Graylog-No-Session-Extension, X-Requested-With, X-Requested-By");
    responseContext.getHeaders().add("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE, OPTIONS");
    // In order to avoid redoing the preflight thingy for every request, see http://stackoverflow.com/a/12021982/1088469
    responseContext.getHeaders().add("Access-Control-Max-Age", "600"); // 10 minutes seems to be the maximum allowable value
  }
}

代码示例来源：origin: oracle/helidon

.addParam(AuditEvent.AuditParam.plain("method", fc.getMethod()))
.addParam(AuditEvent.AuditParam.plain("path", fc.getResourcePath()))
.addParam(AuditEvent.AuditParam.plain("status", String.valueOf(responseContext.getStatus())))
.addParam(AuditEvent.AuditParam.plain("subject",
                   OptionalHelper.from(securityContext.user())

代码示例来源：origin: oracle/helidon

@Override
public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
  Span span = (Span) requestContext.getProperty(SPAN_PROPERTY);
  if (span == null) {
    return; // unknown state
  }
  if (responseContext.getStatus() >= 500) {
    Tags.ERROR.set(span, true);
    span.log(CollectionsHelper.mapOf(
        "event", "error",
        "status", responseContext.getStatus()
    ));
  }
  span.finish();
  TracingContext.remove();
}

代码示例来源：origin: Graylog2/graylog2-server

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
    if (LOG.isDebugEnabled()) {
      try {
        final String rawQuery = requestContext.getUriInfo().getRequestUri().getRawQuery();
        final Date requestDate = requestContext.getDate();
        final String userName = RestTools.getUserNameFromRequest(requestContext);
        final String remoteAddress = RestTools.getRemoteAddrFromRequest(response.getRequest(), trustedProxies);
        final String userAgent = requestContext.getHeaderString(HttpHeaders.USER_AGENT);

        LOG.debug("{} {} [{}] \"{} {}{}\" {} {} {}",
            remoteAddress,
            userName == null ? "-" : userName,
            (requestDate == null ? "-" : requestDate),
            requestContext.getMethod(),
            requestContext.getUriInfo().getPath(),
            (rawQuery == null ? "" : "?" + rawQuery),
            (userAgent == null ? "-" : userAgent),
            responseContext.getStatus(),
            responseContext.getLength());
      } catch (Exception e) {
        LOG.error("Error while processing REST API access log", e);
      }
    }
  }
}

代码示例来源：origin: docker-java/docker-java

@Override
public void filter(final ContainerRequestContext requestContext, final ContainerResponseContext responseContext)
    throws IOException {
  final long id = aid.incrementAndGet();
  final StringBuilder b = new StringBuilder();
  printResponseLine(b, "Server responded with a response", id, responseContext.getStatus());
  printPrefixedHeaders(b, id, RESPONSE_PREFIX, responseContext.getStringHeaders());
  if (printEntity && responseContext.hasEntity()) {
    final OutputStream stream = new LoggingStream(b, responseContext.getEntityStream());
    responseContext.setEntityStream(stream);
    requestContext.setProperty(ENTITY_LOGGER_PROPERTY, stream);
    // not calling log(b) here - it will be called by the interceptor
  } else {
    log(b);
  }
}

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

@Override
  public void filter(final ContainerRequestContext requestContext, final ContainerResponseContext responseContext)
      throws IOException {
    if (!logger.isLoggable(level)) {
      return;
    }
    final Object requestId = requestContext.getProperty(LOGGING_ID_PROPERTY);
    final long id = requestId != null ? (Long) requestId : _id.incrementAndGet();

    final StringBuilder b = new StringBuilder();

    printResponseLine(b, "Server responded with a response", id, responseContext.getStatus());
    printPrefixedHeaders(b, id, RESPONSE_PREFIX, responseContext.getStringHeaders());

    if (responseContext.hasEntity() && printEntity(verbosity, responseContext.getMediaType())) {
      final OutputStream stream = new LoggingStream(b, responseContext.getEntityStream());
      responseContext.setEntityStream(stream);
      requestContext.setProperty(ENTITY_LOGGER_PROPERTY, stream);
      // not calling log(b) here - it will be called by the interceptor
    } else {
      log(b);
    }
  }
}

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

@Override
  public void filter(final ContainerRequestContext requestContext, final ContainerResponseContext responseContext)
      throws IOException {
    if (!logger.isLoggable(level)) {
      return;
    }
    final Object requestId = requestContext.getProperty(LOGGING_ID_PROPERTY);
    final long id = requestId != null ? (Long) requestId : _id.incrementAndGet();

    final StringBuilder b = new StringBuilder();

    printResponseLine(b, "Server responded with a response", id, responseContext.getStatus());
    printPrefixedHeaders(b, id, RESPONSE_PREFIX, responseContext.getStringHeaders());

    if (responseContext.hasEntity() && printEntity(verbosity, responseContext.getMediaType())) {
      final OutputStream stream = new LoggingStream(b, responseContext.getEntityStream());
      responseContext.setEntityStream(stream);
      requestContext.setProperty(ENTITY_LOGGER_PROPERTY, stream);
      // not calling log(b) here - it will be called by the interceptor
    } else {
      log(b);
    }
  }
}

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

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException
  {
   if (responseContext.getStatus() == 200)
   {
     responseContext.getHeaders().putSingle(HttpHeaders.CACHE_CONTROL, cacheControl);
   }
  }
}

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

@Override
public void filter(ContainerRequestContext requestContext,
          ContainerResponseContext responseContext)
          throws IOException {
  if (responseContext.getStatus() == 200) {
    for (Annotation i : responseContext.getEntityAnnotations()) {
      if (i instanceof Status) {
        responseContext.setStatus(((Status) i).value());
        break;
      }
    }
  }
}

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

@Override
public void filter(ContainerRequestContext requestContext,
          ContainerResponseContext responseContext) throws IOException {
 ResteasyDeployment deployment = ResteasyContext.getContextData(ResteasyDeployment.class);
 if (deployment != null)
 {
   Boolean disable = (Boolean) deployment.getProperty(ResteasyContextParameters.RESTEASY_DISABLE_HTML_SANITIZER);
   if (disable != null && disable)
   {
    return;
   }
 }
 if (HttpResponseCodes.SC_BAD_REQUEST == responseContext.getStatus()) {
   Object entity = responseContext.getEntity();
   if (entity != null && entity instanceof String) {
    ArrayList<Object> contentTypes = (ArrayList<Object>)responseContext.getHeaders().get("Content-Type");
    if (contentTypes != null  && containsHtmlText(contentTypes)) {
      String escapedMsg = escapeXml((String) entity);
      responseContext.setEntity(escapedMsg);
    }
   }
 }
}

代码示例来源：origin: zalando/logbook

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

代码示例来源：origin: org.jboss.resteasy/resteasy-core

@Override
  public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException
  {
   if (responseContext.getStatus() == 200)
   {
     responseContext.getHeaders().putSingle(HttpHeaders.CACHE_CONTROL, cacheControl);
   }
  }
}

代码示例来源：origin: org.apache.rave/rave-core-api

@Override
  public void filter(ContainerRequestContext containerRequestContext, ContainerResponseContext containerResponseContext) throws IOException {
    if (containerResponseContext.getStatus() == Response.Status.OK.getStatusCode()) {

      Object o = containerResponseContext.getEntity();

      if (o == null) {
        containerResponseContext.setStatus(Response.Status.NO_CONTENT.getStatusCode());
      }
    }
  }
}

代码示例来源：origin: org.apache.geronimo/geronimo-opentracing-common

@Override
  public void filter(final ContainerRequestContext req, final ContainerResponseContext resp) {
    ofNullable(req.getProperty(OpenTracingFilter.class.getName())).map(Scope.class::cast)
        .ifPresent(scope -> Tags.HTTP_STATUS.set(scope.span(), resp.getStatus()));
  }
}

代码示例来源：origin: io.dropwizard/dropwizard-jersey

@Override
public void filter(final ContainerRequestContext request,
    final ContainerResponseContext response) throws IOException {
  String id = request.getHeaderString(REQUEST_ID);
  if (Strings.isNullOrEmpty(id)) {
    id = generateRandomUuid().toString();
  }
  logger.trace("method={} path={} request_id={} status={} length={}",
      request.getMethod(), request.getUriInfo().getPath(), id,
      response.getStatus(), response.getLength());
  response.getHeaders().putSingle(REQUEST_ID, id);
}

代码示例来源：origin: apache/cxf

@SuppressWarnings("unchecked")
@Override
public void filter(final ContainerRequestContext requestContext,
    final ContainerResponseContext responseContext) throws IOException {
  super.stopTraceSpan(requestContext.getHeaders(), responseContext.getHeaders(),
    responseContext.getStatus(), (TraceScopeHolder<TraceScope>)requestContext.getProperty(TRACE_SPAN));
}

代码示例来源：origin: apache/cxf

@SuppressWarnings("unchecked")
@Override
public void filter(final ContainerRequestContext requestContext,
    final ContainerResponseContext responseContext) throws IOException {
  super.stopTraceSpan(requestContext.getHeaders(), responseContext.getHeaders(),
    responseContext.getStatus(), (TraceScopeHolder<TraceScope>)requestContext.getProperty(TRACE_SPAN));
}

代码示例来源：origin: org.apache.cxf/cxf-integration-tracing-brave

@SuppressWarnings("unchecked")
@Override
public void filter(final ContainerRequestContext requestContext,
    final ContainerResponseContext responseContext) throws IOException {
  super.stopTraceSpan(requestContext.getHeaders(), responseContext.getHeaders(),
    responseContext.getStatus(), (TraceScopeHolder<TraceScope>)requestContext.getProperty(TRACE_SPAN));
}

内容来源于网络，如有侵权，请联系作者删除！

ContainerResponseContext

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com