Создание управляемых событиями потребителей в конечной точке файла без RouteBuilder в Camel 2.24 - PullRequest
0 голосов
/ 17 апреля 2020

Я хочу запустить процессор при появлении файла в каталоге. 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 и который полностью настраивает конечную точку файла. Можете ли вы помочь мне?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...