🎨 新增消息管道ServerConfiguration的自定义配置类

Author: hengboy

api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/MessagePipeServerAutoConfiguration.java

@@ -27,15 +27,33 @@ public MessagePipeServerAutoConfiguration(MessagePipeServerProperties messagePip
         this.messagePipeServerProperties = messagePipeServerProperties;
     }
 
+    /**
+     * Instantiate the wrapper class of {@link ServerConfigurationCustomizer}
+     *
+     * @param customizers The {@link ServerConfigurationCustomizer} object provider
+     * @return The {@link ServerConfigurationCustomizers} instance
+     */
+    @Bean
+    @ConditionalOnMissingBean
+    public ServerConfigurationCustomizers serverConfigurationCustomizers(
+        ObjectProvider<ServerConfigurationCustomizer> customizers) {
+        List<ServerConfigurationCustomizer> sortedCustomizers =
+            customizers.orderedStream().collect(Collectors.toList());
+        return new ServerConfigurationCustomizers(sortedCustomizers);
+    }
+
     /**
      * Create {@link ServerConfiguration} instance
      *
      * @return The {@link ServerConfiguration} instance
      * @see MessagePipeServerProperties
+     * @see ServerConfigurationCustomizer
+     * @see ServerConfigurationCustomizers
      */
     @Bean
-    public ServerConfiguration serverConfiguration() {
-        return messagePipeServerProperties.getConfiguration();
+    public ServerConfiguration serverConfiguration(ServerConfigurationCustomizers customizers) {
+        ServerConfiguration configuration = messagePipeServerProperties.getConfiguration();
+        return customizers.customizer(configuration);
     }
 
     /**

api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/ServerConfigurationCustomizer.java

@@ -0,0 +1,11 @@
+package org.minbox.framework.api.boot.autoconfigure.message.pipe.server;
+
+import org.minbox.framework.message.pipe.server.config.ServerConfiguration;
+
+/**
+ * @author 恒宇少年
+ */
+@FunctionalInterface
+public interface ServerConfigurationCustomizer {
+    void customize(ServerConfiguration serverConfiguration);
+}

api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/message/pipe/server/ServerConfigurationCustomizers.java

@@ -0,0 +1,25 @@
+package org.minbox.framework.api.boot.autoconfigure.message.pipe.server;
+
+import org.minbox.framework.message.pipe.server.config.ServerConfiguration;
+import org.springframework.boot.util.LambdaSafe;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * @author 恒宇少年
+ */
+public class ServerConfigurationCustomizers {
+    private List<ServerConfigurationCustomizer> customizers;
+
+    public ServerConfigurationCustomizers(List<ServerConfigurationCustomizer> customizers) {
+        this.customizers = (customizers != null) ? new ArrayList<>(customizers) : Collections.emptyList();
+    }
+
+    public ServerConfiguration customizer(ServerConfiguration configuration) {
+        LambdaSafe.callbacks(ServerConfigurationCustomizer.class, this.customizers, configuration)
+            .withLogger(ServerConfigurationCustomizer.class).invoke((customizer) -> customizer.customize(configuration));
+        return configuration;
+    }
+}