智云3.0机场1适配内容提交

nishiwei

5 days ago 3f43e40ed1a1e9f66b3ad2862da9dbc4b710c712

 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() {
@@ -109,6 +112,14 @@

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

    /**
     * 机场1：航线准备异常通知通道。
     */
    @Bean(name = ChannelName.INBOUND_EVENTS_FLIGHT_SETUP_EXCEPTION_NOTIFY)
    public MessageChannel eventsFlightSetupExceptionNotifyChannel() {
        return new DirectChannel();
    }

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