V1.1.0 for dock

sean.zhou

2022-07-22 9b2eedb85d53ca32610c32c6e50b5230ab3b16cf

 src/main/java/com/dji/sample/component/mqtt/config/MqttMessageChannel.java

@@ -74,7 +74,7 @@

    @Bean(name = ChannelName.INBOUND_OSD)
    public MessageChannel osdChannel() {
        return new DirectChannel();
        return new ExecutorChannel(threadPool);
    }

    @Bean(name = ChannelName.DEFAULT)
@@ -87,4 +87,54 @@
        return new DirectChannel();
    }

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

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

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

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

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

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

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

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

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

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

}