如何使用消息分块器设置 Mule_Correlation_ID

How set Mule_Correlation_ID using meassage chunk splitter

在将一个副本转换为 csv 数据并将另一个副本转换为固定长度并将 "enable correlation id" 设置为 "always" 选项后,我将 json 数据馈送到分散收集器并将消息发送到两个消息块拆分器.但是 mule message chunk splitter 对 json 和 csv 数据都设置了相同的 Mule_Correlation_id 并且反过来这与正常 "correlation_id" 相同不明白为什么会发生这种情况,即使我正在设置启用"always" 选项的相关 ID。这是流程的屏幕截图。

以上是 mule flow 的屏幕截图。这是消息块拆分器的设置

有什么我需要改变才能变得不同吗"mule_correlation_id"。

Mule 3.x splitter documentation 提到它设置了以下出站属性:

  • MULE_CORRELATION_GROUP_SIZE: 原始消息被拆分成的片段数。
  • MULE_CORRELATION_SEQUENCE: 片段在组中的位置。
  • MULE_CORRELATION_ID:整个组的单个 ID(同一原始消息的所有输出片段共享相同的值)。

从同一条原始消息拆分出来的所有部分将共享相同的 MULE_CORRELATION_ID,因此它们可以关联在一起。每个部分都应该在相同的 MULE_CORRELATION_ID.

中有一个唯一的 MULE_CORRELATION_SEQUENCE