我有一个sftp适配器，它可以从远程位置下载文件并进行转换。但是，它将跳过备用文件。i、 e如果sftp中的主机文件是1.zip、2.zip、3.zip，那么它只处理1.zip和3.zip

@Bean
@Primary
public IntegrationFlow sftpInboundFlow(){
...
..
 SftpInboundChannelAdapterSpec messageSourceBuilder = 
...
..

IntegrationFlowBuilder flowBuilder = IntegrationFlows
                .from(messageSourceBuilder, consumerSpec())
                .log(Level.INFO, m -> "INBOUND: " + m.getPayload() + " HEADERS: " + m.getHeaders()
                );

return flowBuilder.channel(INBOUND_CHANNEL).handle(new MessageHandler());

// Works fine if changed to 
// flowBuilder.channel(INBOUND_CHANNEL).get();
// 
}

    @Bean
    public IntegrationFlow uncompressionfileFlow() {

        UnZipTransformer unZipTransformer = new UnZipTransformer();

        IntegrationFlowBuilder flowBuilder = IntegrationFlows.from(INBOUND_CHANNEL).transform(unZipTransformer)
                .split(new UnZipAbstractMessageSplitter(prop1, prop2))
                .log(Level.INFO, m -> "OUTBOUND: " + m.getPayload() + " HEADERS: " + m.getHeaders())
                .enrichHeaders(h -> h.headerExpression(FileHeaders.ORIGINAL_FILE,
                        "payload.headers['" + FileHeaders.FILENAME + "']"));
        return flowBuilder.channel(OUTBOUND_CHANNEL).get();
    }