Xiajijian
2026-03-03 3579c8e2bf38781e634c8ba4a6347b009002d9ba
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();
    }
}