Spring 来自 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。

现在假设我得到了三个部门 ID 为（1 和 3）的记录

我想在 DataSplitterTransformer() 处暂停并再次将消息路由到 "ValidFile"

部门 1 有两条消息 1，部门 3 有一条消息

这可能吗？

Answer 1

这样的解释你的配置不是很清楚。听起来您忽略了一个事实，即有 .split() 用于从单个消息生成多个输出，还有一个 .route() 用于根据选择器逻辑决定将每条消息发送到何处。

你真的可以回到 ValidFile 频道，你也可以使用 defaultOutputToParentFlow().

继续主流程

有关详细信息，请参阅他们的 Javadoc。

Spring 来自 Transformer 的集成路由消息

Spring Integration route message from Transformer

java

spring

spring-integration

spring-integration-dsl