disable refresh by default

Author: DanielLiu1123

src/main/java/com/freemanan/starter/httpexchange/HttpClientBeanRegistrar.java

@@ -105,7 +105,7 @@ public void registerHttpClientBean(BeanDefinitionRegistry registry, String class
         abd.setLazyInit(true);
 
         try {
-            if (SPRING_CLOUD_CONTEXT_PRESENT) {
+            if (properties.getRefresh().isEnabled() && SPRING_CLOUD_CONTEXT_PRESENT) {
                 abd.setScope("refresh");
                 BeanDefinitionHolder scopedProxy =
                         ScopedProxyUtils.createScopedProxy(new BeanDefinitionHolder(abd, className), registry, false);

src/main/java/com/freemanan/starter/httpexchange/HttpClientsProperties.java

@@ -47,13 +47,18 @@ public class HttpClientsProperties implements InitializingBean {
      * Default headers, will be added to all the requests.
      */
     private List<Header> headers = new ArrayList<>();
-
+    /**
+     * Channels configuration.
+     */
     private List<Channel> channels = new ArrayList<>();
-
     /**
      * Whether to convert Java bean to query parameters, default value is {@code false}.
      */
     private boolean beanToQuery = false;
+    /**
+     * Refresh configuration.
+     */
+    private Refresh refresh = new Refresh();
 
     @Data
     @NoArgsConstructor
@@ -142,4 +147,15 @@ public static class Channel {
          */
         private List<Class<?>> classes = new ArrayList<>();
     }
+
+    @Data
+    public static class Refresh {
+        public static final String PREFIX = HttpClientsProperties.PREFIX + ".refresh";
+        /**
+         * Whether to enable refresh exchange clients, default {@code false}.
+         *
+         * <p> NOTE: this feature needs {@code spring-cloud-context} dependency in the classpath.
+         */
+        private boolean enabled = false;
+    }
 }

src/test/java/com/freemanan/starter/httpexchange/DynamicRefreshTests.java

@@ -27,9 +27,14 @@ void testDynamicRefresh() {
         var ctx = new SpringApplicationBuilder(Cfg.class)
                 .properties("server.port=" + port)
                 .properties("http-exchange.base-url=http://localhost:" + port)
+                .properties("http-exchange.refresh.enabled=true")
                 .run();
 
+        // 3 beans: controller bean, api bean, proxied api bean
+        assertThat(ctx.getBeanProvider(FooApi.class)).hasSize(3);
+
         FooApi api = ctx.getBean(FooApi.class);
+
         assertThat(api.get()).isEqualTo("OK");
 
         System.setProperty("http-exchange.base-url", "http://localhost:" + port + "/v2");

src/test/java/com/freemanan/starter/httpexchange/ExtendShadedTests.java

@@ -37,7 +37,7 @@ void userApiFirst_whenHaveControllerAndApiBeans() {
                 .properties("server.port=" + port)
                 .run();
         long count = ctx.getBeanProvider(FooApi.class).stream().count();
-        assertThat(count).isEqualTo(3);
+        assertThat(count).isEqualTo(2);
 
         FooApi fooApi = ctx.getBean(FooApi.class);
         assertThat(fooApi).isNotInstanceOf(FooController.class);

src/test/java/com/freemanan/starter/httpexchange/ExtendTests.java

@@ -34,7 +34,7 @@ void userApiFirst_whenHaveControllerAndApiBeans() {
                 .profiles("ControllerApiTests")
                 .properties("server.port=" + port)
                 .run();
-        assertThat(ctx.getBeanProvider(FooApi.class)).hasSize(3);
+        assertThat(ctx.getBeanProvider(FooApi.class)).hasSize(2);
 
         FooApi fooApi = ctx.getBean(FooApi.class);
         assertThat(fooApi).isNotInstanceOf(FooController.class);