nishiwei
6 days ago 3f43e40ed1a1e9f66b3ad2862da9dbc4b710c712
ard-sample/src/main/java/com/ard/sample/component/mqtt/config/MqttMessageChannel.java
@@ -115,6 +115,14 @@
        return new DirectChannel();
    }
    /**
     * 机场1:航线准备异常通知通道。
     */
    @Bean(name = ChannelName.INBOUND_EVENTS_FLIGHT_SETUP_EXCEPTION_NOTIFY)
    public MessageChannel eventsFlightSetupExceptionNotifyChannel() {
        return new DirectChannel();
    }
    @Bean(name = ChannelName.INBOUND_EVENTS_FILE_UPLOAD_CALLBACK)
    public MessageChannel eventsFileUploadCallbackChannel() {
        return new DirectChannel();
@@ -175,4 +183,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();
    }
}