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