Code optimization and logic refactoring (opengoofy#909)

* Code optimization and logic refactoring

* Code optimization and logic refactoring

* Remove useless modules and refactor code

* Remove kafka modules

* Remove kafka code

Author: magestacks

hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterBeanContainer.java

@@ -29,7 +29,7 @@
 public class ThreadPoolAdapterBeanContainer implements InitializingBean {
 
     /**
-     * Store three-party thread pool framework bean instances.
+     * Store three-party thread pool framework bean instances
      */
     public static final Map<String, ThreadPoolAdapter> THREAD_POOL_ADAPTER_BEAN_CONTAINER = new ConcurrentHashMap<>();
 

hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterRegisterAction.java

@@ -28,16 +28,15 @@ public interface ThreadPoolAdapterRegisterAction {
     /**
      * Get thread pool adapter cache configs.
      *
-     * @param threadPoolAdapterMap
+     * @param threadPoolAdapterMap thread-pool adapter map
      * @return List<ThreadPoolAdapterCacheConfig>
      */
     List<ThreadPoolAdapterCacheConfig> getThreadPoolAdapterCacheConfigs(Map<String, ThreadPoolAdapter> threadPoolAdapterMap);
 
     /**
      * Do register.
      *
-     * @param cacheConfigList
-     * @return
+     * @param cacheConfigList cache config list
      */
     void doRegister(List<ThreadPoolAdapterCacheConfig> cacheConfigList);
 }

hippo4j-adapter/hippo4j-adapter-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/ThreadPoolAdapterScheduler.java

@@ -18,6 +18,7 @@
 package cn.hippo4j.adapter.hystrix;
 
 import cn.hippo4j.common.design.builder.ThreadFactoryBuilder;
+import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.concurrent.ScheduledExecutorService;
@@ -31,6 +32,7 @@ public class ThreadPoolAdapterScheduler {
 
     private static final int TASK_INTERVAL_SECONDS = 10;
 
+    @Getter
     private final ScheduledExecutorService scheduler;
 
     public ThreadPoolAdapterScheduler() {
@@ -41,10 +43,11 @@ public ThreadPoolAdapterScheduler() {
                         .build());
     }
 
-    public ScheduledExecutorService getScheduler() {
-        return scheduler;
-    }
-
+    /**
+     * Gt task interval seconds.
+     *
+     * @return task interval seconds
+     */
     public int getTaskIntervalSeconds() {
         return TASK_INTERVAL_SECONDS;
     }

hippo4j-adapter/hippo4j-adapter-kafka/pom.xml

@@ -105,7 +105,6 @@ public void onApplicationEvent(ApplicationStartedEvent event) {
                     log.warn("Custom thread pools only support ThreadPoolExecutor");
                 }
             }
-
         });
     }
 }

hippo4j-adapter/hippo4j-adapter-kafka/src/main/java/cn/hippo4j/adapter/kafka/KafkaThreadPoolAdapter.java

@@ -39,7 +39,7 @@
 import static cn.hippo4j.common.constant.ChangeThreadPoolConstants.CHANGE_DELIMITER;
 
 /**
- * Spring cloud stream rabbimq thread-pool adapter.
+ * Spring cloud stream rabbit-mq thread-pool adapter.
  */
 @Slf4j
 public class SpringCloudStreamRabbitMQThreadPoolAdapter implements ThreadPoolAdapter, ApplicationListener<ApplicationStartedEvent> {

hippo4j-adapter/hippo4j-adapter-rabbitmq/src/main/java/cn/hippo4j/adapter/rabbitmq/RabbitMQThreadPoolAdapter.java

@@ -34,12 +34,12 @@
 public abstract class AbstractWebThreadPoolService implements WebThreadPoolService, ApplicationRunner {
 
     /**
-     * Thread pool executor.
+     * Thread pool executor
      */
     protected volatile Executor executor;
 
     /**
-     * Get web thread pool by server.
+     * Get web thread pool by server
      *
      * @param webServer
      * @return

hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/pom.xml

@@ -30,7 +30,7 @@ public class WebThreadPoolHandlerChoose {
     /**
      * Choose the web thread pool service bean.
      *
-     * @return
+     * @return web thread pool service bean
      */
     public WebThreadPoolService choose() {
         WebThreadPoolService webThreadPoolService;

hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaThreadPoolAdapter.java

@@ -35,9 +35,9 @@ public ThreadPoolRunStateInfo supplement(ThreadPoolRunStateInfo poolRunStateInfo
         long used = MemoryUtil.heapMemoryUsed();
         long max = MemoryUtil.heapMemoryMax();
         String memoryProportion = StringUtil.newBuilder(
-                "已分配: ",
+                "Allocation: ",
                 ByteConvertUtil.getPrintSize(used),
-                " / 最大可用: ",
+                " / Maximum available: ",
                 ByteConvertUtil.getPrintSize(max));
         poolRunStateInfo.setCurrentLoad(poolRunStateInfo.getCurrentLoad() + "%");
         poolRunStateInfo.setPeakLoad(poolRunStateInfo.getPeakLoad() + "%");

hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rabbitmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rabbitmq/SpringCloudStreamRabbitMQThreadPoolAdapter.java

@@ -14,12 +14,10 @@
         <module>hippo4j-adapter-base</module>
         <module>hippo4j-adapter-dubbo</module>
         <module>hippo4j-adapter-alibaba-dubbo</module>
-        <module>hippo4j-adapter-kafka</module>
         <module>hippo4j-adapter-rabbitmq</module>
         <module>hippo4j-adapter-rocketmq</module>
         <module>hippo4j-adapter-hystrix</module>
         <module>hippo4j-adapter-spring-cloud-stream-rocketmq</module>
-        <module>hippo4j-adapter-spring-cloud-stream-kafka</module>
         <module>hippo4j-adapter-spring-cloud-stream-rabbitmq</module>
         <module>hippo4j-adapter-web</module>
     </modules>