Слушатель файлов в Apache-Camel

Question

Я хочу запрограммировать маршрут Camel в Java, который постоянно проверяет папку для файлов, а затем отправляет их на процессор.

так, как я это знаю, кажется, довольно «грязный» мне:

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()); 

Взгляните на имеющиеся архетипы верблюда-моба: 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(); 
}