org.wso2.msf4j.Request.getHeaders()方法的使用及代码示例

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

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

Request.getHeaders介绍

暂无

代码示例

代码示例来源：origin: wso2/msf4j

  1. @Override
  2.   public boolean interceptRequest(Request request, Response response) throws Exception {
  3.     request.getHeaders().getRequestHeaders().entrySet()
  4.         .forEach(header -> log.info("Header - " + header.getKey() + " : " + header.getValue()));
  5.     return true;
  6.   }
  7. }

代码示例来源：origin: org.wso2.msf4j.example/stockquote-fatjar

  1. /**
  2.  * Retrieve all stocks.
  3.  * http://localhost:8080/stockquote/all
  4.  *
  5.  * @return All stocks will be sent to the client as Json/xml
  6.  * according to the Accept header of the request.
  7.  */
  8. @GET
  9. @Path("/all")
  10. @Produces({"application/json", "text/xml"})
  11. @ApiOperation(
  12.     value = "Get all stocks",
  13.     notes = "Returns all stock items",
  14.     response = Stocks.class,
  15.     responseContainer = "List")
  16. public Stocks getAllStocks(@Context Request request) {
  17.   request.getHeaders().getRequestHeaders().entrySet().forEach(entry -> System.out.println(entry.getKey() + "=" + entry
  18.       .getValue()));
  19.   return new Stocks(stockQuotes.values());
  20. }

代码示例来源：origin: wso2/msf4j

  1. /**
  2.  * Retrieve all stocks.
  3.  * http://localhost:8080/stockquote/all
  4.  *
  5.  * @return All stocks will be sent to the client as Json/xml
  6.  * according to the Accept header of the request.
  7.  */
  8. @GET
  9. @Path("/all")
  10. @Produces({"application/json", "text/xml"})
  11. @ApiOperation(
  12.     value = "Get all stocks",
  13.     notes = "Returns all stock items",
  14.     response = Stocks.class,
  15.     responseContainer = "List")
  16. public Stocks getAllStocks(@Context Request request) {
  17.   request.getHeaders().getRequestHeaders().entrySet().forEach(entry -> log.info(entry.getKey() + "=" + entry
  18.       .getValue()));
  19.   return new Stocks(stockQuotes.values());
  20. }

代码示例来源：origin: wso2/msf4j

  1. /**
  2.  * Retrieve all stocks.
  3.  * http://localhost:8080/stockquote/all
  4.  *
  5.  * @return All stocks will be sent to the client as Json/xml
  6.  * according to the Accept header of the request.
  7.  */
  8. @GET
  9. @Path("/all")
  10. @Produces({"application/json", "text/xml"})
  11. @ApiOperation(
  12.     value = "Get all stocks",
  13.     notes = "Returns all stock items",
  14.     response = Stocks.class,
  15.     responseContainer = "List")
  16. public Stocks getAllStocks(@Context Request request) {
  17.   request.getHeaders().getRequestHeaders().entrySet().forEach(entry -> System.out.println(entry.getKey() + "=" + entry
  18.       .getValue()));
  19.   return new Stocks(stockQuotes.values());
  20. }

代码示例来源：origin: org.wso2.analytics.apim/org.wso2.analytics.apim.rest.api.file

  1. @Override
  2. public Response usageUploadFilePost(InputStream analyticsInputStream, FileInfo analyticsDetail,
  3.     Request request) throws NotFoundException {
  4.   HttpHeaders httpHeaders = request.getHeaders();
  5.   String uploadedFileName = httpHeaders.getHeaderString(UploadServiceConstants.FILE_NAME_HEADER);

代码示例来源：origin: org.wso2.carbon.uiserver/org.wso2.carbon.uiserver

  1. Map<String, String> httpHeaders = request.getHeaders().getRequestHeaders().entrySet().stream()
  2.     .collect(Collectors.toMap(Map.Entry::getKey, entry -> entry.getValue().get(0)));
  3. this.headers = Collections.unmodifiableMap(httpHeaders);

代码示例来源：origin: org.wso2.carbon.uis/org.wso2.carbon.uis

  1. Map<String, String> httpHeaders = request.getHeaders().getRequestHeaders().entrySet().stream()
  2.     .collect(Collectors.toMap(Map.Entry::getKey, entry -> entry.getValue().get(0)));
  3. this.headers = Collections.unmodifiableMap(httpHeaders);

代码示例来源：origin: org.wso2.carbon.uuf/org.wso2.carbon.uuf.httpconnector.msf4j

  1. request.getHeaders().getAll().forEach(header -> this.headers.put(header.getName(), header.getValue()));
  2. String cookieHeader = this.headers.get(HttpHeaders.COOKIE);
  3. this.cookies = (cookieHeader == null) ? Collections.emptyMap() :

代码示例来源：origin: org.wso2.carbon.uis/org.wso2.carbon.uis.core

  1. request.getHeaders().getAll().forEach(header -> this.headers.put(header.getName(), header.getValue()));
  2. String cookieHeader = this.headers.get(HttpHeaders.COOKIE);
  3. this.cookies = (cookieHeader == null) ? Collections.emptyMap() :

代码示例来源：origin: wso2/msf4j

  1. @Override
  2.   public boolean interceptRequest(Request request, Response response) throws Exception {
  3.     HttpHeaders headers = request.getHeaders();
  4.     if (headers != null) {
  5.       String jwtHeader = headers.getHeaderString(JWT_HEADER);
  6.       if (jwtHeader != null) {
  7.         SignedJWT signedJWT = SignedJWT.parse(jwtHeader);
  8.         ReadOnlyJWTClaimsSet readOnlyJWTClaimsSet = signedJWT.getJWTClaimsSet();
  9.         if (readOnlyJWTClaimsSet != null) {
  10.           // Do something with claims
  11.           return true;
  12.         }
  13.       }
  14.     }
  15.     response.setHeader(javax.ws.rs.core.HttpHeaders.WWW_AUTHENTICATE, AUTH_TYPE_JWT);
  16.     response.setStatus(javax.ws.rs.core.Response.Status.UNAUTHORIZED.getStatusCode());
  17.     return false;
  18.   }
  19. }

代码示例来源：origin: wso2/msf4j

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   SecurityErrorCode errorCode;
  4.   try {
  5.     HttpHeaders headers = request.getHeaders();
  6.     String authHeader = headers.getHeaderString(AUTHORIZATION_HTTP_HEADER);
  7.     if (authHeader != null && !authHeader.isEmpty()) {
  8.       return validateToken(authHeader);
  9.     } else {
  10.       throw new MSF4JSecurityException(SecurityErrorCode.AUTHENTICATION_FAILURE,
  11.           "Missing Authorization header is the request.`");
  12.     }
  13.   } catch (MSF4JSecurityException e) {
  14.     errorCode = e.getErrorCode();
  15.     log.error(e.getMessage() + " Requested Path: " + request.getUri());
  16.   }
  17.   handleSecurityError(errorCode, response);
  18.   return false;
  19. }

代码示例来源：origin: org.wso2.msf4j/msf4j-core

  1. @Override
  2. public boolean interceptRequest(Request request, Response response) throws Exception {
  3.   SecurityErrorCode errorCode;
  4.   try {
  5.     HttpHeaders headers = request.getHeaders();
  6.     String authHeader = headers.getHeaderString(AUTHORIZATION_HTTP_HEADER);
  7.     if (authHeader != null && !authHeader.isEmpty()) {
  8.       return validateToken(authHeader);
  9.     } else {
  10.       throw new MSF4JSecurityException(SecurityErrorCode.AUTHENTICATION_FAILURE,
  11.           "Missing Authorization header is the request.`");
  12.     }
  13.   } catch (MSF4JSecurityException e) {
  14.     errorCode = e.getErrorCode();
  15.     log.error(e.getMessage() + " Requested Path: " + request.getUri());
  16.   }
  17.   handleSecurityError(errorCode, response);
  18.   return false;
  19. }

代码示例来源：origin: org.wso2.carbon.analytics-common/org.wso2.carbon.analytics.auth.rest.api

  1. .extractTokenFromHeaders(request.getHeaders(), IdPClientConstants.WSO2_SP_TOKEN);
  2. if (accessToken != null) {
  3.   try {

代码示例来源：origin: org.wso2.carbon.analytics-common/org.wso2.carbon.analytics.msf4j.interceptor.common

  1. Headers headers = request.getHeaders();
  2. String authorizationHeader = request.getHeader(IdPClientConstants.AUTHORIZATION_HEADER);
  3. if (authorizationHeader != null) {

代码示例来源：origin: org.wso2.carbon.apimgt/org.wso2.carbon.apimgt.authenticator

  1. .extractTokenFromHeaders(request.getHeaders(), AuthenticatorConstants.ACCESS_TOKEN_2);
  2. if (accessToken != null) {
  3.   try {

代码示例来源：origin: org.wso2.carbon.analytics/org.wso2.carbon.analytics.msf4j.interceptor.common

  1. HttpHeaders headers = request.getHeaders();
  2. String authorizationHeader = request.getHeader(SPConstants.AUTHORIZATION_HEADER);
  3. if (authorizationHeader != null && authorizationHeader.contains(" ")) {

代码示例来源：origin: org.wso2.carbon.analytics-common/org.wso2.carbon.analytics.auth.rest.api

  1. if (IdPClientConstants.REFRESH_GRANT_TYPE.equals(grantType)) {
  2.   refToken = AuthUtil
  3.       .extractTokenFromHeaders(request.getHeaders(), IdPClientConstants.WSO2_SP_REFRESH_TOKEN);
  4.   if (refToken == null) {
  5.     LOG.error("Unable to extract refresh token from the header for the request '"

代码示例来源：origin: wso2/msf4j

  1. httpMonitoringEvent.setServiceContext(servicePath);
  2. HttpHeaders httpHeaders = request.getHeaders();

代码示例来源：origin: org.wso2.carbon.apimgt/org.wso2.carbon.apimgt.authenticator

  1. if (AuthenticatorConstants.REFRESH_GRANT.equals(grantType)) {
  2.   refToken = AuthUtil
  3.       .extractTokenFromHeaders(request.getHeaders(), AuthenticatorConstants.REFRESH_TOKEN_2);
  4.   if (refToken == null) {
  5.     ErrorDTO errorDTO = new ErrorDTO();

代码示例来源：origin: org.wso2.carbon.identity.gateway/org.wso2.carbon.identity.gateway.api

  1. /**
  2.  * Update GatewayRequestBuilder.
  3.  *
  4.  * @param builder Builder.
  5.  * @param request MS4J request
  6.  * @throws GatewayClientException GatewayClientException
  7.  */
  8. protected void create(T builder, Request request)
  9.     throws GatewayClientException {
  10.   request.getHeaders().getAll().forEach(header -> {
  11.     builder.addHeader(header.getName(), header.getValue());
  12.   });
  13.   builder.setMethod(request.getHttpMethod());
  14.   builder.setContentType(request.getContentType());
  15.   builder.setRequestURI(request.getUri());
  16.   builder.setMethod(request.getHttpMethod());
  17.   builder.setAttributes((Map) request.getProperties());
  18.   builder.addParameter(Constants.QUERY_PARAMETERS,
  19.       (Serializable) request.getProperty(Constants.QUERY_PARAMETERS));
  20.   builder.addParameter(Constants.BODY_PARAMETERS, (Serializable) request.getProperty(Constants.BODY_PARAMETERS));
  21.   String[] queryStringParams = request.getUri().split("\\?");
  22.   if (queryStringParams.length > 1) {
  23.     builder.setQueryString(queryStringParams[1]);
  24.   } else {
  25.     builder.setQueryString(queryStringParams[0]);
  26.   }
  27.   if (logger.isDebugEnabled()) {
  28.     logger.debug("Successfully Updated the request builder in GatewayRequestBuilderFactory.");
  29.   }
  30. }

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

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