From 14011f96caec688a121f9a9f19a0f27c37a67770 Mon Sep 17 00:00:00 2001 From: Maciej Malewski Date: Wed, 3 Feb 2021 10:45:43 +0100 Subject: Upgrade Spring Boot and Spring Cloud versions Spring Boot from 2.2.4.RELEASE to 2.4.2 Spring Cloud from Greenwich.SR1 to 2020.0.1 Issue-ID: DCAEGEN2-2537 Signed-off-by: Maciej Malewski Change-Id: I51c8c450133a68435799802f548bb16ba562550c --- .../dcaegen2/services/bootstrap/CbsPropertySourceLocator.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/bootstrap/CbsPropertySourceLocator.java') diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/bootstrap/CbsPropertySourceLocator.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/bootstrap/CbsPropertySourceLocator.java index 7b660202..c068988c 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/bootstrap/CbsPropertySourceLocator.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/bootstrap/CbsPropertySourceLocator.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * PNF-REGISTRATION-HANDLER * ================================================================================ - * Copyright (C) 2019 NOKIA Intellectual Property. All rights reserved. + * Copyright (C) 2019-2021 NOKIA Intellectual Property. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -31,6 +31,7 @@ import org.springframework.cloud.bootstrap.config.PropertySourceLocator; import org.springframework.core.env.Environment; import org.springframework.core.env.MapPropertySource; import org.springframework.core.env.PropertySource; +import reactor.util.retry.Retry; import java.util.Map; @@ -63,9 +64,9 @@ public class CbsPropertySourceLocator implements PropertySourceLocator { Map properties = cbsClientFactoryFacade.createCbsClient(cbsClientConfiguration) .flatMap(cbsClient -> cbsClient.get(CbsRequests.getAll(RequestDiagnosticContext.create()))) .doOnError(e -> LOGGER.warn("Failed fetching config properties from CBS - retrying...", e)) - .retryBackoff(cbsProperties.getFetchRetries().getMaxAttempts(), - cbsProperties.getFetchRetries().getFirstBackoff(), - cbsProperties.getFetchRetries().getMaxBackoff()) + .retryWhen(Retry. + backoff(cbsProperties.getFetchRetries().getMaxAttempts(), cbsProperties.getFetchRetries().getFirstBackoff()). + maxBackoff(cbsProperties.getFetchRetries().getMaxBackoff())) .doOnNext(this::updateCbsConfig) .map(cbsJsonToPropertyMapConverter::convertToMap) .block(); -- cgit 1.2.3-korg