X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=information-coordinator-service%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fics%2Fclients%2FAsyncRestClientFactory.java;h=9a6c4f70e6f87a8c63bdaef8984b14fe8f30c01c;hb=71c1b158a19fbec07ff67fabda5012f7c6734494;hp=cfac5cf1b2e3d00ff41b5e80d356e12c8ae3a7e3;hpb=c6916032d124066c6009e0db070a0cebb9c1ea5f;p=nonrtric.git diff --git a/information-coordinator-service/src/main/java/org/oransc/ics/clients/AsyncRestClientFactory.java b/information-coordinator-service/src/main/java/org/oransc/ics/clients/AsyncRestClientFactory.java index cfac5cf1..9a6c4f70 100644 --- a/information-coordinator-service/src/main/java/org/oransc/ics/clients/AsyncRestClientFactory.java +++ b/information-coordinator-service/src/main/java/org/oransc/ics/clients/AsyncRestClientFactory.java @@ -38,7 +38,6 @@ import java.security.cert.X509Certificate; import java.util.Collections; import java.util.List; import java.util.stream.Collectors; - import javax.net.ssl.KeyManagerFactory; import org.oransc.ics.configuration.WebClientConfig; @@ -55,8 +54,9 @@ public class AsyncRestClientFactory { private final SslContextFactory sslContextFactory; private final HttpProxyConfig httpProxyConfig; + private final SecurityContext securityContext; - public AsyncRestClientFactory(WebClientConfig clientConfig) { + public AsyncRestClientFactory(WebClientConfig clientConfig, SecurityContext securityContext) { if (clientConfig != null) { this.sslContextFactory = new CachingSslContextFactory(clientConfig); this.httpProxyConfig = clientConfig.httpProxyConfig(); @@ -65,6 +65,7 @@ public class AsyncRestClientFactory { this.sslContextFactory = null; this.httpProxyConfig = null; } + this.securityContext = securityContext; } public AsyncRestClient createRestClientNoHttpProxy(String baseUrl) { @@ -79,13 +80,13 @@ public class AsyncRestClientFactory { if (this.sslContextFactory != null) { try { return new AsyncRestClient(baseUrl, this.sslContextFactory.createSslContext(), - useHttpProxy ? httpProxyConfig : null); + useHttpProxy ? httpProxyConfig : null, this.securityContext); } catch (Exception e) { String exceptionString = e.toString(); logger.error("Could not init SSL context, reason: {}", exceptionString); } } - return new AsyncRestClient(baseUrl, null, httpProxyConfig); + return new AsyncRestClient(baseUrl, null, httpProxyConfig, this.securityContext); } private class SslContextFactory {