我有一个队列通道和一个带有轮询器和任务 Actuator “监听”的链，并行进行一些处理 . 我想要做的是以这样的方式配置它，即我可以根据某些逻辑/属性路由特定的消息，以确保特定的消息'type'始终由任务 Actuator 的特定线程处理 .
示例：消息其中： PAYLOAD_PROPERTY & 1 == 0 始终转到线程1， PAYLOAD_PROPERTY & 1 == 1 转到线程2（请注意，这只是2个线程的示例 - 我可以在这里轻松使用路由器但我可以想象有逻辑 - 就像模数操作 - 用于10个线程另外一句话：线程1和线程2不能同时处理相同的'type'消息 . 因此，目的不仅仅是对它进行负载 balancer - 它是基于某些逻辑坚持使用相同的线程 .
我最初的想法是以某种方式使用 Channels 调度程序（它可以有 load-balancer-ref 和 task-executor ），但不确定这是否会起作用，因为我有一个带有轮询器的链，我需要进一步处理它 .
您能否建议具有上述工作流程的最佳组件设置是什么？
1 回答
在“标准”任务 Actuator 中没有类似的东西 .
删除队列通道可能更容易，路由器（订阅直接通道）路由到10个单独的 Actuator 通道，每个通道配置一个单线程 Actuator .