У меня есть маршрут с пользовательским агрегатором, он выглядит так:
Я хотел бы обернуть детали, чтобы разработчики могли просто добавить одну строку к своим маршрутам, чтобы получить функциональность. Могу ли я обернуть эти строки так, чтобы у меня был класс, который расширяет 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