sftp适配器正在跳过备用文件

gblwokeq  于 2021-07-23  发布在  Java
关注(0)|答案(1)|浏览(374)

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

  1. @Bean
  2. @Primary
  3. public IntegrationFlow sftpInboundFlow(){
  4. ...
  5. ..
  6. SftpInboundChannelAdapterSpec messageSourceBuilder =
  7. ...
  8. ..
  9. IntegrationFlowBuilder flowBuilder = IntegrationFlows
  10. .from(messageSourceBuilder, consumerSpec())
  11. .log(Level.INFO, m -> "INBOUND: " + m.getPayload() + " HEADERS: " + m.getHeaders()
  12. );
  13. return flowBuilder.channel(INBOUND_CHANNEL).handle(new MessageHandler());
  14. // Works fine if changed to
  15. // flowBuilder.channel(INBOUND_CHANNEL).get();
  16. //
  17. }
  18. @Bean
  19. public IntegrationFlow uncompressionfileFlow() {
  20. UnZipTransformer unZipTransformer = new UnZipTransformer();
  21. IntegrationFlowBuilder flowBuilder = IntegrationFlows.from(INBOUND_CHANNEL).transform(unZipTransformer)
  22. .split(new UnZipAbstractMessageSplitter(prop1, prop2))
  23. .log(Level.INFO, m -> "OUTBOUND: " + m.getPayload() + " HEADERS: " + m.getHeaders())
  24. .enrichHeaders(h -> h.headerExpression(FileHeaders.ORIGINAL_FILE,
  25. "payload.headers['" + FileHeaders.FILENAME + "']"));
  26. return flowBuilder.channel(OUTBOUND_CHANNEL).get();
  27. }
zd287kbt

zd287kbt1#

你所描述的是完全相关的循环调度策略上 DirectChannel : https://docs.spring.io/spring-integration/docs/current/reference/html/core.html#channel-实现directchannel。而根据你的配置,我们确实有两个相同的用户 INBOUND_CHANNEL : channel(INBOUND_CHANNEL).handle(new MessageHandler()) . from(INBOUND_CHANNEL).transform(unZipTransformer) 我不确定您的目标是什么,但是代码片段中的逻辑比从sftp轮询文件并处理它们要复杂得多。
您应该修改到目前为止的内容,但这不是sftp入站通道适配器问题,更像是同一直接通道上的两个竞争消费者。

相关问题