diff --git a/src/main/java/com/intuit/springwebclient/client/CommonSpringWebClient.java b/src/main/java/com/intuit/springwebclient/client/CommonSpringWebClient.java index 7f27874..48b48e6 100644 --- a/src/main/java/com/intuit/springwebclient/client/CommonSpringWebClient.java +++ b/src/main/java/com/intuit/springwebclient/client/CommonSpringWebClient.java @@ -4,6 +4,7 @@ import java.util.Objects; import java.util.function.Consumer; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; @@ -18,7 +19,6 @@ import com.intuit.springwebclient.entity.ClientHttpResponse; import com.intuit.springwebclient.retryHandler.RetryHandlerFactory; -import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import reactor.core.publisher.Mono; import reactor.util.retry.Retry; @@ -28,11 +28,14 @@ */ @Slf4j @Component -@AllArgsConstructor public class CommonSpringWebClient { private final WebClient webClient; - /** + public CommonSpringWebClient(@Qualifier("RWebPulseClient") WebClient webClient) { + this.webClient = webClient; + } + + /** * Execute Blocking http request. * @param httpRequest * @return diff --git a/src/main/java/com/intuit/springwebclient/config/WebClientConfiguration.java b/src/main/java/com/intuit/springwebclient/config/WebClientConfiguration.java index e79ce3f..ecae0e9 100644 --- a/src/main/java/com/intuit/springwebclient/config/WebClientConfiguration.java +++ b/src/main/java/com/intuit/springwebclient/config/WebClientConfiguration.java @@ -41,7 +41,7 @@ public HttpClient webHttpClient(){ .option(ChannelOption.SO_TIMEOUT, webClientConfiguration.getHttpClientConfig().getSocketTimeoutMillis()); } - @Bean + @Bean("RWebPulseClient") public WebClient createWebClient(){ return WebClient.builder() .clientConnector(new ReactorClientHttpConnector(webHttpClient()))