Сообщение маршрута Spring Integration от Transformer

Question

У меня есть настройка интеграции как

    IntegrationFlows.from("ValidFile")
    .transform(
    Transformer(new FindTheDepartItbelongs()) //basically file has to match to some depoartment
    .transform(new FileParserTransformer()
.transform(new DataSplitterTransformer()
    .transformer(new CustomerTransformer()
    .handle (o -> {})

Как вы видите, DataSplitterTransformer () в основном, я должен сгруппировать данные, например, ID отдела.

Теперь допустим, я получил тризаписи с идентификатором отдела (1 и 3)

Я хочу сделать паузу в DataSplitterTransformer () и снова направить сообщение в «ValidFile»

Это будет два сообщения 1 для отдела 1 и одно для3

Возможно ли это?

Answer 1

Ваша конфигурация не ясна с таким объяснением.Похоже, вам не хватает того факта, что есть .split() для создания нескольких выходных данных из одного сообщения, а также .route() для решения, куда отправлять каждое сообщение в соответствии с логикой селектора.

Вы действительно можете вернуться кканал ValidFile, а также вы можете продолжить работу в основном потоке, используя defaultOutputToParentFlow().

Для получения дополнительной информации см. их Javadocs.