Gibt es eine Möglichkeit, den eingehenden Kanaladapter zu stoppen, nachdem Dateien vom sftp-Server mit Java-Konfiguration empfangen wurden

Question

Verwenden von Java-Konfiguration zum Starten/Stoppen des Inbound-Channel-Adapters, versuchte ich mit Steuer-Bus Aber ich war nicht erfolgreich, Bitte bereitstellen Ein Beispiel mit Java-Konfiguration.

Answer 1

Die füllt SourcePollingChannelAdapter Bean mit dem Namen basierend auf dem Muster [configurationComponentName].[methodName].[decapitalizedAnnotationClassShortName]. Zum Beispiel:

@Configuration 
@EnableIntegration 
public class MyConfiguration { 

    @InboundChannelAdapter(channel = "inputChannel") 
    @Bean 
    public MessageSource<String> myMessageSource() { 
     return() -> new GenericMessage<>("bar"); 
    } 

} 

wird eine Bohne Namen wie myConfiguration.myMessageSource.inboundChannelAdapter haben.

Die SourcePollingChannelAdapter ist in der Tat Lifecycle und kann durch den Control Bus verwaltet werden:

controlBusChannel.send(
     new GenericMessage("@'myConfiguration.myMessageSource.inboundChannelAdapter'.stop()"));