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(); } }