X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-adaptor-java%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fdmaapadapter%2Fclients%2FAsyncRestClient.java;h=746fdd75b67daf69b454a8549e62156d797bbd59;hb=aa73209488503ee51db068c6143c7d4ec298a036;hp=8b3efed567f41f7cfa349d25240f5571f04aeb14;hpb=46a0fd717e5f49ebae6cb2c4fbcf54f0e329dc86;p=nonrtric.git diff --git a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/clients/AsyncRestClient.java b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/clients/AsyncRestClient.java index 8b3efed5..746fdd75 100644 --- a/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/clients/AsyncRestClient.java +++ b/dmaap-adaptor-java/src/main/java/org/oran/dmaapadapter/clients/AsyncRestClient.java @@ -47,6 +47,7 @@ import reactor.netty.transport.ProxyProvider; /** * Generic reactive REST client. */ +@SuppressWarnings("java:S4449") // @Add Nullable to third party api public class AsyncRestClient { private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass()); @@ -83,7 +84,7 @@ public class AsyncRestClient { } public Mono postWithAuthHeader(String uri, String body, String username, String password, - MediaType mediaType) { + @Nullable MediaType mediaType) { Object traceTag = createTraceTag(); logger.debug("{} POST (auth) uri = '{}{}''", traceTag, baseUrl, uri); logger.trace("{} POST body: {}", traceTag, body); @@ -111,16 +112,6 @@ public class AsyncRestClient { return retrieve(traceTag, request); } - public Mono> putForEntity(String uri) { - Object traceTag = createTraceTag(); - logger.debug("{} PUT uri = '{}{}''", traceTag, baseUrl, uri); - logger.trace("{} PUT body: ", traceTag); - RequestHeadersSpec request = getWebClient() // - .put() // - .uri(uri); - return retrieve(traceTag, request); - } - public Mono put(String uri, String body) { return putForEntity(uri, body) // .map(this::toBody);