org.apache.cxf.jaxrs.client.WebClient.getRequestContext()方法的使用及代码示例

x33g5p2x  于2022-02-02 转载在 其他  
字(4.2k)|赞(0)|评价(0)|浏览(104)

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

WebClient.getRequestContext介绍

暂无

代码示例

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

protected void doWriteBody(Message outMessage,
                Object body,
                Type bodyType,
                Annotation[] customAnns,
                OutputStream os) throws Fault {
    Map<String, Object> requestContext = WebClient.this.getRequestContext(outMessage);
    Class<?> requestClass = null;
    Type requestType = null;
    if (requestContext != null) {
      requestClass = (Class<?>)requestContext.get(REQUEST_CLASS);
      requestType = (Type)requestContext.get(REQUEST_TYPE);
    }
    if (bodyType != null) {
      requestType = bodyType;
    }
    Annotation[] anns = customAnns != null ? customAnns : new Annotation[]{};
    boolean isAssignable = requestClass != null && requestClass.isAssignableFrom(body.getClass());
    try {
      writeBody(body, outMessage,
           requestClass == null || !isAssignable ? body.getClass() : requestClass,
           requestType == null || !isAssignable ? body.getClass() : requestType,
           anns, os);
    } catch (Exception ex) {
      throw new Fault(ex);
    }
  }
}

代码示例来源:origin: org.apache.cxf/cxf-rt-rs-client

protected void doWriteBody(Message outMessage,
                Object body,
                Type bodyType,
                Annotation[] customAnns,
                OutputStream os) throws Fault {
    Map<String, Object> requestContext = WebClient.this.getRequestContext(outMessage);
    Class<?> requestClass = null;
    Type requestType = null;
    if (requestContext != null) {
      requestClass = (Class<?>)requestContext.get(REQUEST_CLASS);
      requestType = (Type)requestContext.get(REQUEST_TYPE);
    }
    if (bodyType != null) {
      requestType = bodyType;
    }
    Annotation[] anns = customAnns != null ? customAnns : new Annotation[]{};
    boolean isAssignable = requestClass != null && requestClass.isAssignableFrom(body.getClass());
    try {
      writeBody(body, outMessage,
           requestClass == null || !isAssignable ? body.getClass() : requestClass,
           requestType == null || !isAssignable ? body.getClass() : requestType,
           anns, os);
    } catch (Exception ex) {
      throw new Fault(ex);
    }
  }
}

代码示例来源:origin: org.apache.cxf/cxf-bundle-jaxrs

protected void doWriteBody(Message outMessage, 
                Object body,
                Type bodyType,
                Annotation[] customAnns,
                OutputStream os) throws Fault {    
    
    Map<String, Object> requestContext = WebClient.this.getRequestContext(outMessage);
    Class<?> requestClass = null;
    Type requestType = null;
    if (requestContext != null) {
      requestClass = (Class<?>)requestContext.get(REQUEST_CLASS);
      requestType = (Type)requestContext.get(REQUEST_TYPE);
    }
    if (bodyType != null) {
      requestType = bodyType;
    }
    
    Annotation[] anns = customAnns != null ? customAnns : new Annotation[]{};
    boolean isAssignable = requestClass != null && requestClass.isAssignableFrom(body.getClass());
    try {
      writeBody(body, outMessage, 
           requestClass == null || !isAssignable ? body.getClass() : requestClass,
           requestType == null || !isAssignable ? body.getClass() : requestType, 
           anns, os);
    } catch (Exception ex) {
      throw new Fault(ex);
    }
  }
}

代码示例来源:origin: org.apache.cxf/cxf-bundle-jaxrs

private Message finalizeMessage(String httpMethod, 
                MultivaluedMap<String, String> headers, 
                Object body, 
                Class<?> requestClass,
                Type inGenericType,
                Class<?> responseClass, 
                Type outGenericType,
                Exchange exchange,
                Map<String, Object> invContext) {
//CHECKSTYLE:ON    
  URI uri = getCurrentURI();
  Message m = createMessage(body, httpMethod, headers, uri, exchange, 
      invContext, false);
  setSupportOnewayResponseProperty(m);
  Map<String, Object> reqContext = getRequestContext(m);
  reqContext.put(Message.HTTP_REQUEST_METHOD, httpMethod);
  reqContext.put(REQUEST_CLASS, requestClass);
  reqContext.put(REQUEST_TYPE, inGenericType);
  reqContext.put(RESPONSE_CLASS, responseClass);
  reqContext.put(RESPONSE_TYPE, outGenericType);
  
  m.getInterceptorChain().add(bodyWriter);
 
  setPlainOperationNameProperty(m, httpMethod + ":" + uri.toString());
  return m;
}

代码示例来源:origin: org.apache.cxf/cxf-rt-rs-client

m.put(Annotation.class.getName(), inAnns);
Map<String, Object> reqContext = getRequestContext(m);
reqContext.put(Message.HTTP_REQUEST_METHOD, httpMethod);
reqContext.put(REQUEST_CLASS, requestClass);

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

m.put(Annotation.class.getName(), inAnns);
Map<String, Object> reqContext = getRequestContext(m);
reqContext.put(Message.HTTP_REQUEST_METHOD, httpMethod);
reqContext.put(REQUEST_CLASS, requestClass);

相关文章

WebClient类方法