mindol1004/getting-started
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

edited restconsumer.java

Browse Source
This commit is contained in:
Pratik Das
2021-12-27 19:48:12 +05:30
parent 451e92ee5e
commit 31c5e50424
1 changed files with 16 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
spring-boot/resttemplate/src/main/java/io/pratik/restclient/RestConsumer.java
View File

@@ -124,33 +124,35 @@ public class RestConsumer {
}
private RequestCallback requestCallback(final Product updatedProduct) {
return clientHttpRequest -> {
ObjectMapper mapper = new ObjectMapper();
mapper.writeValue(clientHttpRequest.getBody(), updatedProduct);
clientHttpRequest.getHeaders().add(
HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
clientHttpRequest.getHeaders().add(
HttpHeaders.AUTHORIZATION, "Bearer Ahwye82939jeb ");
};
}
public void getProductAsStream() {
final Product updatedProduct = new Product("Television", "Samsung",1145.67,"S001");
final Product fetchProductRequest = new Product("Television", "Samsung",1145.67,"S001");
RestTemplate restTemplate = new RestTemplate();
String resourceUrl
= "http://localhost:8080/products";
RequestCallback requestCallback = request -> request.getHeaders()
.setAccept(Arrays.asList(MediaType.APPLICATION_OCTET_STREAM, MediaType.ALL));
RequestCallback requestCallback = request -> {
ObjectMapper mapper = new ObjectMapper();
mapper.writeValue(request.getBody(),
fetchProductRequest);
request.getHeaders()
.setAccept(Arrays.asList(
MediaType.APPLICATION_OCTET_STREAM,
MediaType.ALL));
};
ResponseExtractor<Void> responseExtractor = response -> {
Path path = Paths.get("some/path");
Files.copy(response.getBody(), path);
return null;
};
restTemplate.execute(resourceUrl, HttpMethod.GET, requestCallback(updatedProduct), responseExtractor );
restTemplate.execute(resourceUrl,
HttpMethod.GET,
requestCallback,
responseExtractor );
}