Apache-Camel中的文件監聽器

Question

我想要在Java中編程一個不斷檢查文件夾文件夾的Camel Route，然後將它們發送給處理器。

我不知道它的方式似乎很「髒」我說：

from("file:C:\\exampleSource").process(new Processor() 
       { 
        @Override 
        public void process(Exchange msg) 
        { 
         File file = msg.getIn().getBody(File.class); 
         Filecheck(file); 
        } 
       }); 

      } 
     }); 
     camelContext.start(); 
     while (true) 
     { 
      // run 
     } 

是否有實現一個更好的辦法？

在此先感謝。

Answer 1

您還可以將你的文件處理專用類：

import java.io.File; 
import org.apache.camel.Exchange; 
import org.apache.camel.Processor; 

public class FileProcessor implements Processor { 

    @Override 
    public void process(Exchange exchange) throws Exception { 
     File file = exchange.getIn().getBody(File.class); 
     processFile(file); 
    } 

    private void processFile(File file) { 
     //TODO process file 
    } 
} 

，然後用它如下：

from("file:C:\\exampleSource").process(new FileProcessor()); 

看看可用的駱駝maven原型：http://camel.apache.org/camel-maven-archetypes.html其中c amel-archetype-java反映你的情況

Answer 2

這裏是做一個也許更清潔的方式：

public static void main(String[] args) throws Exception { 
    Main camelMain = new Main(); 
    camelMain.addRouteBuilder(new RouteBuilder() { 
     @Override 
     public void configure() throws Exception { 
      from("file:C:\\xyz") 
        // do whatever 
      ; 
     } 
    }); 
    camelMain.run(); 
}