Я хочу запустить процессор при появлении файла в каталоге. URL моего файла выглядит так:
file:{{file.root}}in?include=.*\.csv&charset=windows-1251&move=../out/done
Процедура, которая связывает URL с процессором, выглядит следующим образом:
MessageProcessor getOrCreateConsumer(CamelContext context, String uri) {
Endpoint endpoint = context.getEndpoint(uri);
endpoint.setCamelContext(context); // added this out of desperation, doesn't help
processor = new MessageProcessor();
try {
Consumer consumer = endpoint.createConsumer(processor);
endpoint.start(); // do we need this at all? works the same without it
consumer.start();
} catch (Exception e) {
throw new RuntimeException(e);
}
return processor;
}
}
MessageProcessor
- это процессор это делает некоторые вещи для обмена.
Кажется, все работает , за исключением , файл не перемещается в каталог ../out/done
. Во время отладки я не могу получить, когда конечная точка настроена на обмен сообщениями файлов с этой операцией.
Я думаю, что мне не хватает некоторого магического вызова c, который обычно вызывается RouteBuilder и который полностью настраивает конечную точку файла. Можете ли вы помочь мне?