2025-12-09 zwy 增加INBOUND_STATE_SPLITTER、INBOUND_STATE_ROUTER的通道Bean定义，解决“没有...

zhaowenyu

2025-12-09 72b6d1dce413abe4d0db4c53b5f1b6d77e9dd94f

2025-12-09 zwy 增加INBOUND_STATE_SPLITTER、INBOUND_STATE_ROUTER的通道Bean定义，解决“没有订阅者” 的错误。

 ard-sample/src/main/java/com/ard/sample/component/mqtt/config/MqttMessageChannel.java

@@ -175,4 +175,14 @@
        return new DirectChannel();
    }

    // 在MqttMessageChannel.java中补充以下Bean
    @Bean(name = ChannelName.INBOUND_STATE_SPLITTER)
    public MessageChannel stateSplitterChannel() {
        return new DirectChannel();
    }

    @Bean(name = ChannelName.INBOUND_STATE_ROUTER)
    public MessageChannel stateRouterChannel() {
        return new DirectChannel();
    }
}