加工後彈簧整合移動文件

Question

加工文件後如何在彈簧整合後處理文件..？ 我按照http://xpadro.blogspot.com/2016/07/spring-integration-polling-file.html落實文件投票，但我需要補充的onSuccess和的OnError跨國事件（用了XML配置）

Answer 1

我不知道你所說的「交易」的意思，文件系統通常是不能交易的，但您可以在流程中向最終消費者添加建議...

@SpringBootApplication 
public class So40625031Application { 

    public static void main(String[] args) { 
     SpringApplication.run(So40625031Application.class, args); 
    } 

    @Bean 
    public IntegrationFlow flow() { 
     return IntegrationFlows.from(
        Files.inboundAdapter(new File("/tmp/foo")), e -> e.poller(Pollers.fixedDelay(1000))) 
       .transform(Transformers.fileToString()) 
       .handle("processor", "process", e -> e.advice(advice())) 
       .get(); 
    } 

    @Bean 
    public Processor processor() { 
     return new Processor(); 
    } 

    @Bean 
    public AbstractRequestHandlerAdvice advice() { 
     return new AbstractRequestHandlerAdvice() { 

      @Override 
      protected Object doInvoke(ExecutionCallback callback, Object target, Message<?> message) throws Exception { 
       File file = message.getHeaders().get(FileHeaders.ORIGINAL_FILE, File.class); 
       try { 
        Object result = callback.execute(); 
        file.renameTo(new File("/tmp/bar", file.getName())); 
        System.out.println("File renamed after success"); 
        return result; 
       } 
       catch (Exception e) { 
        file.renameTo(new File("/tmp/baz", file.getName())); 
        System.out.println("File renamed after failure"); 
        throw e; 
       } 
      } 
     }; 
    } 

    public static class Processor { 

     public void process(String in) { 
      System.out.println(in); 
     } 

    } 

}