diff options
author | 2020-12-10 11:49:02 +0100 | |
---|---|---|
committer | 2020-12-10 12:19:04 +0100 | |
commit | 1e6f4d9c7ea75302f4b902dbbe13642b6d20d716 (patch) | |
tree | 4d8ed9f901b36ac26931c31fe36123eaa34d92c0 /components/bbs-event-processor/src | |
parent | f6fe21b365fc6b89f79b01d6b08a2f75d7ea4dad (diff) |
Upgrade SpringBoot and SDK2.1.0
Add missing .gitreview file
Issue-ID: DCAEGEN2-2537
Signed-off-by: tkogut <tomasz.kogut@nokia.com>
Change-Id: I519b850b689236b4e2e34bb19ead6b7522b60c48
Diffstat (limited to 'components/bbs-event-processor/src')
-rw-r--r-- | components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/config/ConsulConfigurationGateway.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/config/ConsulConfigurationGateway.java b/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/config/ConsulConfigurationGateway.java index 4ac85495..b660b718 100644 --- a/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/config/ConsulConfigurationGateway.java +++ b/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/config/ConsulConfigurationGateway.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * BBS-RELOCATION-CPE-AUTHENTICATION-HANDLER * ================================================================================ - * Copyright (C) 2019 NOKIA Intellectual Property. All rights reserved. + * Copyright (C) 2019-2020 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 java.util.HashMap; import java.util.HashSet; import java.util.Map; import java.util.Set; +import java.util.function.Function; import org.jetbrains.annotations.NotNull; import org.onap.bbs.event.processor.exceptions.ApplicationEnvironmentException; @@ -48,6 +49,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import reactor.core.Disposable; +import reactor.util.retry.Retry; @Component public class ConsulConfigurationGateway { @@ -128,7 +130,7 @@ public class ConsulConfigurationGateway { // Create the client and use it to get the configuration cbsFetchPipeline = CbsClientFactory.createCbsClient(cbsClientConfig) .doOnError(e -> LOGGER.warn("CBS Configuration fetch failed with error: {}", e)) - .retry(e -> true) + .retryWhen(Retry.from(Function.identity())) .flatMapMany(cbsClient -> cbsClient.updates(cbsRequest, initialDelay, period)) .subscribe(this::parseConsulRetrievedConfiguration, this::handleErrors); } |