(feign.Request request, Options options)
| 55 | } |
| 56 | |
| 57 | @Override |
| 58 | public feign.Response execute(feign.Request request, Options options) throws IOException { |
| 59 | final Response response = |
| 60 | clientBuilder |
| 61 | .connectTimeout(options.connectTimeoutMillis(), TimeUnit.MILLISECONDS) |
| 62 | .readTimeout(options.readTimeoutMillis(), TimeUnit.MILLISECONDS) |
| 63 | .build() |
| 64 | .target(request.url()) |
| 65 | .request() |
| 66 | .headers(toMultivaluedMap(request.headers())) |
| 67 | .method(request.httpMethod().name(), createRequestEntity(request)); |
| 68 | |
| 69 | return feign.Response.builder() |
| 70 | .request(request) |
| 71 | .body( |
| 72 | response.readEntity(InputStream.class), |
| 73 | integerHeader(response, HttpHeaders.CONTENT_LENGTH)) |
| 74 | .headers(toMap(response.getStringHeaders())) |
| 75 | .status(response.getStatus()) |
| 76 | .reason(response.getStatusInfo().getReasonPhrase()) |
| 77 | .build(); |
| 78 | } |
| 79 | |
| 80 | private Entity<byte[]> createRequestEntity(feign.Request request) { |
| 81 | if (request.body() == null) { |
nothing calls this directly
no test coverage detected