job-launching-gateway 动态作业参数

Question

我正在使用 Spring 批量集成，我必须动态传递作业参数。下面是我的服务激活器类，它将我的消息转换为 JobLaunchRequest。

注意：没有指定频道名称，因为它在链中。

<int:service-activator id="msgToJob">
    <bean class="org.xyz.transformer.MessageToJob">
        <property name="job" ref="myJob"/>
    </bean>
</int:service-activator>

如何从有效负载或标头等动态传递作业引用？ 请提出合适的解决方案。

我有一个计划，使用router来确定job，使用对应的service activator channel。有没有更好的办法？

Answer 1

<int:header-enricher ... >
    <int:header name="jobRef" expression="@someJob" />
</int:header-enricher>

使用 Spring 集成中的运行时 SpEL 表达式，@ 在应用程序上下文中引用一个 bean。