|
|
@@ -38,10 +38,10 @@ public class RequestBodyFilter implements GlobalFilter, Ordered {
|
|
|
HttpHeaders headers = exchange.getRequest().getHeaders();
|
|
|
MediaType contentType = headers.getContentType();
|
|
|
if (contentType != null && contentType.isCompatibleWith(MediaType.APPLICATION_JSON)) {
|
|
|
- Flux<DataBuffer> body = exchange.getRequest().getBody();
|
|
|
+// Flux<DataBuffer> body = exchange.getRequest().getBody();
|
|
|
|
|
|
}else{
|
|
|
- log.info("Request query params: {}", exchange.getRequest().getQueryParams());
|
|
|
+ log.info("Request query params: {}", exchange.getRequest().getQueryParams());
|
|
|
}
|
|
|
log.info("Request headers: {}", headers);
|
|
|
|
|
|
@@ -52,14 +52,14 @@ public class RequestBodyFilter implements GlobalFilter, Ordered {
|
|
|
}));
|
|
|
}
|
|
|
|
|
|
- private Mono<String> readJsonBody(Flux<DataBuffer> body) {
|
|
|
- return this.messageReader.readMono(
|
|
|
- Mono.just(ServerHttpRequestDecorator.empty().body(BodyInserters.fromDataBuffers(body))),
|
|
|
- String.class,
|
|
|
- MediaType.APPLICATION_JSON,
|
|
|
- Map.of()
|
|
|
- );
|
|
|
- }
|
|
|
+// private Mono<String> readJsonBody(Flux<DataBuffer> body) {
|
|
|
+// return this.messageReader.readMono(
|
|
|
+// Mono.just(ServerHttpRequestDecorator.empty().body(BodyInserters.fromDataBuffers(body))),
|
|
|
+// String.class,
|
|
|
+// MediaType.APPLICATION_JSON,
|
|
|
+// Map.of()
|
|
|
+// );
|
|
|
+// }
|
|
|
|
|
|
@Override
|
|
|
public int getOrder() {
|