zhaowenyu
2026-02-27 b5c022295a2d678edff3f54d9ee10e2fa1515c2d
ard-sample/src/main/java/com/ard/sample/component/mqtt/config/MqttMessageChannel.java
@@ -66,6 +66,9 @@
    public MessageChannel stateCapacityChannel() {
        return new DirectChannel();
    }
    // 机场与飞行器视频切换状态通道
    @Bean(name = ChannelName.INBOUND_STATE_STATUS)
    public MessageChannel stateStatusChannel() { return new DirectChannel(); }
    @Bean(name = ChannelName.INBOUND_STATE_PAYLOAD_UPDATE)
    public MessageChannel statePayloadUpdateChannel() {
@@ -172,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();
    }
}