Расширение Camel DSL - PullRequest
       7

Расширение Camel DSL

0 голосов
/ 22 июня 2019

У меня есть маршрут с пользовательским агрегатором, он выглядит так: enter image description here

Я хотел бы обернуть детали, чтобы разработчики могли просто добавить одну строку к своим маршрутам, чтобы получить функциональность. Могу ли я обернуть эти строки так, чтобы у меня был класс, который расширяет ProcessorDefinition, а затем добавить этот ProcessorDefinition к маршрутам, которые в этом нуждаются, чтобы он выглядел как расширение DSL? Если да, то способ addOutput() является ли способ сделать это?

Примерно так:

from("file:" + FILE_PATH + "?noop=true")
        .log("Detected file")
        .split().tokenize("\n")
        .streaming()
        .unmarshal(bindy)

        .addProcessorDefinition(new MyCustomAggregation())

        .to("direct:handleAggregatedRecords");

Где

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