aboutsummaryrefslogtreecommitdiffstats
path: root/lib/src/main/java/org/onap/portalng/bff/config/BeansConfig.java
diff options
context:
space:
mode:
Diffstat (limited to 'lib/src/main/java/org/onap/portalng/bff/config/BeansConfig.java')
-rw-r--r--lib/src/main/java/org/onap/portalng/bff/config/BeansConfig.java31
1 files changed, 4 insertions, 27 deletions
diff --git a/lib/src/main/java/org/onap/portalng/bff/config/BeansConfig.java b/lib/src/main/java/org/onap/portalng/bff/config/BeansConfig.java
index 926108a..3eb5f87 100644
--- a/lib/src/main/java/org/onap/portalng/bff/config/BeansConfig.java
+++ b/lib/src/main/java/org/onap/portalng/bff/config/BeansConfig.java
@@ -33,11 +33,8 @@ import java.util.List;
import lombok.extern.slf4j.Slf4j;
import org.onap.portalng.bff.exceptions.DownstreamApiProblemException;
import org.onap.portalng.bff.utils.Logger;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.beans.factory.config.ConfigurableBeanFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
-import org.springframework.context.annotation.Scope;
import org.springframework.http.codec.ClientCodecConfigurer;
import org.springframework.http.codec.json.Jackson2JsonDecoder;
import org.springframework.http.codec.json.Jackson2JsonEncoder;
@@ -46,7 +43,6 @@ import org.springframework.security.oauth2.client.ReactiveOAuth2AuthorizedClient
import org.springframework.security.oauth2.client.web.reactive.function.client.ServerOAuth2AuthorizedClientExchangeFilterFunction;
import org.springframework.web.reactive.function.client.ExchangeFilterFunction;
import org.springframework.web.reactive.function.client.ExchangeStrategies;
-import org.springframework.web.reactive.function.client.WebClient;
import org.zalando.problem.jackson.ProblemModule;
import reactor.core.publisher.Mono;
@@ -55,12 +51,12 @@ import reactor.core.publisher.Mono;
public class BeansConfig {
public static final String OAUTH2_EXCHANGE_FILTER_FUNCTION = "oauth2ExchangeFilterFunction";
- private static final String ID_TOKEN_EXCHANGE_FILTER_FUNCTION = "idTokenExchangeFilterFunction";
- private static final String ERROR_HANDLING_EXCHANGE_FILTER_FUNCTION =
+ public static final String ID_TOKEN_EXCHANGE_FILTER_FUNCTION = "idTokenExchangeFilterFunction";
+ public static final String ERROR_HANDLING_EXCHANGE_FILTER_FUNCTION =
"errorHandlingExchangeFilterFunction";
- private static final String LOG_REQUEST_EXCHANGE_FILTER_FUNCTION =
+ public static final String LOG_REQUEST_EXCHANGE_FILTER_FUNCTION =
"logRequestExchangeFilterFunction";
- private static final String LOG_RESPONSE_EXCHANGE_FILTER_FUNCTION =
+ public static final String LOG_RESPONSE_EXCHANGE_FILTER_FUNCTION =
"logResponseExchangeFilterFunction";
private static final String CLIENT_REGISTRATION_ID = "keycloak";
public static final String X_REQUEST_ID = "X-Request-Id";
@@ -148,25 +144,6 @@ public class BeansConfig {
.build();
}
- // we need to use prototype scope to always create new instance of the bean
- // because internally WebClient.Builder is mutable
- @Bean
- @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
- WebClient.Builder webClientBuilder(
- ExchangeStrategies exchangeStrategies,
- @Qualifier(ID_TOKEN_EXCHANGE_FILTER_FUNCTION)
- ExchangeFilterFunction idTokenExchangeFilterFunction,
- @Qualifier(ERROR_HANDLING_EXCHANGE_FILTER_FUNCTION)
- ExchangeFilterFunction errorHandlingExchangeFilterFunction,
- @Qualifier(LOG_RESPONSE_EXCHANGE_FILTER_FUNCTION)
- ExchangeFilterFunction logResponseExchangeFilterFunction) {
- return WebClient.builder()
- .exchangeStrategies(exchangeStrategies)
- .filter(idTokenExchangeFilterFunction)
- .filter(errorHandlingExchangeFilterFunction)
- .filter(logResponseExchangeFilterFunction);
- }
-
@Bean
Clock clock() {
return Clock.systemUTC();