feign.Request.method()方法的使用及代码示例

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

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

Request.method介绍

暂无

代码示例

代码示例来源:origin: spring-cloud/spring-cloud-sleuth

@Override
public String method(Request request) {
  return request.method();
}

代码示例来源:origin: spring-cloud-incubator/spring-cloud-alibaba

private Request getModifyRequest(Request request) {
  String xid = RootContext.getXID();
  if (StringUtils.isEmpty(xid)) {
    return request;
  }
  Map<String, Collection<String>> headers = new HashMap<>();
  headers.putAll(request.headers());
  List<String> fescarXid = new ArrayList<>();
  fescarXid.add(xid);
  headers.put(RootContext.KEY_XID, fescarXid);
  return Request.create(request.method(), request.url(), headers, request.body(),
      request.charset());
}

代码示例来源:origin: spring-cloud/spring-cloud-sleuth

private Request modifiedRequest(Request request,
    Map<String, Collection<String>> headers) {
  String method = request.method();
  String url = request.url();
  byte[] body = request.body();
  Charset charset = request.charset();
  return Request.create(method, url, headers, body, charset);
}

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

@Override
  public String getHttpMethod() {
    return request.method();
  }
}

代码示例来源:origin: org.springframework.cloud/spring-cloud-sleuth-core

@Override
public String method(Request request) {
  return request.method();
}

代码示例来源:origin: com.ofg/micro-infra-spring-base

static String extractMethod(Request request) {
  return request.method();
}

代码示例来源:origin: com.netflix.feign/feign-core

static FeignException errorReading(Request request, Response ignored, IOException cause) {
 return new FeignException(
   format("%s reading %s %s", cause.getMessage(), request.method(), request.url()),
   cause);
}

代码示例来源:origin: com.netflix.feign/feign-core

static FeignException errorExecuting(Request request, IOException cause) {
  return new RetryableException(
    format("%s executing %s %s", cause.getMessage(), request.method(), request.url()), cause,
    null);
 }
}

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

private Request tracePreRequest(Request request, TraceEvent traceEvent) {
  // set tracing headers to HTTP request
  Map<String, Collection<String>> traceHeaders = new HashMap<>();
  traceHeaders.putAll(request.headers());
  traceHeaders.put(TracingConstants.TRACE_ID_HEADER, Collections.singletonList(traceEvent.getTraceId()));
  traceHeaders.put(TracingConstants.TRACE_ORIGIN_ID_HEADER, Collections.singletonList(traceEvent.getOriginId()));
  // publish event to DAS
  TracingUtil.pushToDAS(traceEvent, dasUrl);
  return Request.create(request.method(), request.url(), traceHeaders, request.body(), request.charset());
}

代码示例来源:origin: spring-cloud/spring-cloud-zookeeper

private Request request(Request request,
    Map<String, Collection<String>> headers) {
  return Request.create(request.method(), request.url(), headers,
      request.body(), request.charset());
}

代码示例来源:origin: org.springframework.cloud/spring-cloud-sleuth-core

private Request modifiedRequest(Request request,
    Map<String, Collection<String>> headers) {
  String method = request.method();
  String url = request.url();
  byte[] body = request.body();
  Charset charset = request.charset();
  return Request.create(method, url, headers, body, charset);
}

代码示例来源:origin: bbilger/jrestless

@BeforeEach
public void setup() throws UnsupportedEncodingException {
  when(feignRequest.url()).thenReturn("/");
  when(feignRequest.method()).thenReturn("GET");
  when(serviceResponse.getStatusCode()).thenReturn(200);
}

代码示例来源:origin: bbilger/jrestless

private static ServiceRequest toServiceRequest(feign.Request feignRequest) {
  return new DefaultServiceRequest(toServiceBody(feignRequest.body()), toServiceHeaders(feignRequest.headers()),
      URI.create(feignRequest.url()), feignRequest.method());
}

代码示例来源:origin: com.marvinformatics.feign/feign-mock

private RequestKey(Request request) {
  this.method = HttpMethod.valueOf(request.method());
  this.url = buildUrl(request);
  this.headers = request.headers();
  this.charset = request.charset();
  this.body = request.body();
}

代码示例来源:origin: com.netflix.feign/feign-ribbon

@Override
public RequestSpecificRetryHandler getRequestSpecificRetryHandler(
  RibbonRequest request, IClientConfig requestConfig) {
 if (clientConfig.get(CommonClientConfigKey.OkToRetryOnAllOperations, false)) {
  return new RequestSpecificRetryHandler(true, true, this.getRetryHandler(), requestConfig);
 }
 if (!request.toRequest().method().equals("GET")) {
  return new RequestSpecificRetryHandler(true, false, this.getRetryHandler(), requestConfig);
 } else {
  return new RequestSpecificRetryHandler(true, true, this.getRetryHandler(), requestConfig);
 }
}

代码示例来源:origin: ppdai-incubator/raptor

protected void preHandle(Request request, Request.Options options) throws Exception {
  //设置url和method到Context中,方便其他地方取
  RaptorContext.getContext().putAttribute(NAME_HTTP_URI, UrlUtils.getUri(request.url()));
  RaptorContext.getContext().putAttribute(NAME_HTTP_METHOD, request.method());
}

代码示例来源:origin: bbilger/jrestless

@Test
public void execute_NoHttpMethodGiven_ShouldFail() throws IOException {
  FeignLambdaClientImpl client = new FeignLambdaClientImpl(serviceResponse);
  when(feignRequest.method()).thenReturn(null);
  assertThrows(NullPointerException.class, () -> client.execute(feignRequest, null));
}

代码示例来源:origin: com.netflix.feign/feign-ribbon

Request toRequest() {
 return new RequestTemplate()
   .method(request.method())
   .append(getUri().toASCIIString())
   .headers(request.headers())
   .body(request.body(), request.charset())
   .request();
}

代码示例来源:origin: bbilger/jrestless

@Test
public void execute_HttpMethodGiven_ShouldRequestWithHttpMethod() throws IOException {
  FeignLambdaClientImpl client = new FeignLambdaClientImpl(serviceResponse);
  when(feignRequest.method()).thenReturn("some method");
  client.execute(feignRequest, null);
  assertEquals("some method", client.getServiceRequest().getHttpMethod());
}

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

@Override
  public Response execute(Request request, Request.Options options) throws IOException {
    Map<String, Collection<String>> traceHeaders = new HashMap<>();
    traceHeaders.putAll(request.headers());
    Request wrappedRequest =
        Request.create(request.method(), request.url(), traceHeaders, request.body(), request.charset());
    HttpClientRequest httpClientRequest = new TraceableHttpClientRequest(wrappedRequest);
    ClientRequestAdapter adapter = new HttpClientRequestAdapter(httpClientRequest, new DefaultSpanNameProvider());
    requestInterceptor.handle(adapter);

    Response response = clientDelegate.execute(wrappedRequest, options);

    HttpResponse httpResponse = new TraceableHttpClientResponse(response);
    ClientResponseAdapter responseAdapter = new HttpClientResponseAdapter(httpResponse);
    responseInterceptor.handle(responseAdapter);
    return response;
  }
}

相关文章