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