X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=cps-ncmp-service%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fcps%2Fncmp%2Fapi%2Fimpl%2Fconfig%2FNcmpConfiguration.java;h=c6ff116a7fb2513784923307240d134dea6f79a2;hb=177d66d0048466cba23eb3a1cc4fe56bf1dce58e;hp=4460094f54cf83aab24bbf74f3bf22a06cbbebd9;hpb=89945a1bde22e0ab0a9fb35d26d8084fadf909ee;p=cps.git diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/config/NcmpConfiguration.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/config/NcmpConfiguration.java index 4460094f54..c6ff116a7f 100644 --- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/config/NcmpConfiguration.java +++ b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/config/NcmpConfiguration.java @@ -72,33 +72,33 @@ public class NcmpConfiguration { */ @Bean @Scope(ConfigurableBeanFactory.SCOPE_SINGLETON) - public static RestTemplate restTemplate(final RestTemplateBuilder restTemplateBuilder, + public static RestTemplate restTemplate(final RestTemplateBuilder restTemplateBuilder, final HttpClientConfiguration httpClientConfiguration) { - + final ConnectionConfig connectionConfig = ConnectionConfig.copy(ConnectionConfig.DEFAULT) .setConnectTimeout(Timeout.of(httpClientConfiguration.getConnectionTimeoutInSeconds())) .build(); - + final PoolingHttpClientConnectionManager connectionManager = PoolingHttpClientConnectionManagerBuilder.create() .setDefaultConnectionConfig(connectionConfig) .setMaxConnTotal(httpClientConfiguration.getMaximumConnectionsTotal()) .setMaxConnPerRoute(httpClientConfiguration.getMaximumConnectionsPerRoute()) .build(); - + final CloseableHttpClient httpClient = HttpClients.custom() .setConnectionManager(connectionManager) .evictExpiredConnections() .evictIdleConnections( TimeValue.of(httpClientConfiguration.getIdleConnectionEvictionThresholdInSeconds())) .build(); - + final ClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory(httpClient); - + final RestTemplate restTemplate = restTemplateBuilder .requestFactory(() -> requestFactory) .setConnectTimeout(httpClientConfiguration.getConnectionTimeoutInSeconds()) .build(); - + setRestTemplateMessageConverters(restTemplate); return restTemplate; }