在 Spring-XD 中基于 Json 参数启动批处理作业

Question

我认为这是不可能的，因为它没有在 XD 文档中列出。

我正在寻找的是一种从包含有效负载中的 jobName 的 RabbitMQ 消息动态启动作业的方法。这将允许我有一个单独的作业队列，我的所有作业都在其中发送，而不必为每个作业设置一个单独的队列。

{
   jobName:"myJob",
   jobParm1: "parm1",
   jobParm2: "parm2"
}

这将允许我有一个单独的作业队列，我的所有作业都可以在其中发送，而不必为每个作业设置一个单独的队列。

This post shows that is possible using http

Answer 1

您可以构建从 rabbit 读取的 XD 流，转换有效负载并调用 http-client 处理器（将输出转储到 null 或 log 接收器）。