Apache Camel: как использовать пользовательские AggregationStrategy

Question

Я хотел бы использовать свой пользовательский AggregationStrategy, который расширяет UseOriginalAggregationStrategy: OriginalPropertyAggregationStrategy

Этот новый пользовательский AggregationStrategy имеет конструктор для принятия экземпляра Exchange

public OriginalPropertyAggregationStrategy(Exchange original, String... properties) {
    super(original, true);
    this.properties = properties;
}

Я намерен передать экземпляр этой Стратегии в Java DSL, но не знаю, как передать Exchange:

.split().method(SplitHelper.class, "invokeSplitter").aggregationStrategy(new OriginalPropertyAggregationStrategy(???, "MSG_RECOVERY_BEAN"))
.stopOnException()
.streaming().parallelProcessing().executorService(threadPoolExecutor)   

Пожалуйста, помогите мне.

Answer 1

Насколько я знаю, вы не можете выбрать, что передать своей стратегии. Вы должны реализовать интерфейс AggregationStrategy.

Поскольку интерфейс задан, вам не нужно беспокоиться о том, как передавать аргументы, Camel сделает это за вас. Вам просто нужно сослаться на класс, который реализует стратегию.

.aggregationStrategy(new FancyAggregationStrategy())