Обогащение заголовка ценностью от трансформатора

Question

У меня есть spring integration flow. Он читает файл.Файл может принадлежать потребителю. Как только я найду потребителя, я хочу добавить CONSUMER к заголовку, чтобы позже я мог использовать, например, In Обработка ошибок Я могу проверить, что я сделалдаже получить consumer, глядя на заголовок.

IntegrationsFlows.from(directorySource)
.transform(new ConsumerFinderTransformer()
.enrichHeaders(h -> h.header("CONSUMER" ,payload)

Как получить полезную нагрузку в enrichHeaders, возвращаемом здесь ConsumerFinderTransformer.

Я не могу найтипуть.Любая помощь будет оценена

Answer 1

Это для вас:

    /**
 * Add a single header specification where the value is a String representation of a
 * SpEL {@link Expression}. If the header exists, it will <b>not</b> be overwritten
 * unless {@link #defaultOverwrite(boolean)} is true.
 * @param name the header name.
 * @param expression the expression.
 * @return the header enricher spec.
 */
public HeaderEnricherSpec headerExpression(String name, String expression) {

Итак, ваш код должен выглядеть так:

.enrichHeaders(h -> h.headerExpression(“CONSUMER" , “payload”)