0

我想问题可能是“MULE_CORRELATION_ID”。我使用标签来处理一批数据。配置如下：

<jdbc-ee:connector name="jdbcConnector" dataSource-ref="dataSource" pollingFrequency="2000" queryTimeout="-1" transactionPerMessage="false" resultSetHandler-ref="resutSetHandler" doc:name="Database"> 
    <jdbc-ee:query key="read" value="SELECT 1 as CID, A.* from ewell_login_user A"></jdbc-ee:query>  
</jdbc-ee:connector>
<file:connector name="output" outputAppend="true" outputPattern="#[function:datestamp].txt" doc:name="File"></file:connector>
<flow name="zhicall-zhongshan" doc:name="zhicall-zhongshan">
    <jdbc-ee:inbound-endpoint queryKey="read" connector-ref="jdbcConnector" doc:name="Database">
    </jdbc-ee:inbound-endpoint>
    <message-properties-transformer doc:name="Message Properties" >
        <add-message-property key="MULE_CORRELATION_GROUP_SIZE" value="10"/>
        <add-message-property key="MULE_CORRELATION_ID" value="10000"/>
    </message-properties-transformer>
    <collection-aggregator timeout="5000" failOnTimeout="false" doc:name="Collection Aggregator"/>
    <custom-transformer encoding="UTF-8" class="com.zhicall.esb.transformer.TestTransFormer" doc:name="Java"/>
    <stdio:outbound-endpoint doc:name="STDIO" responseTimeout="10000" system="OUT" encoding="UTF-8"/>
</flow>
4

1 回答 1

2

MULE_CORRELATION_ID 对于每组消息必须是唯一的。
你不应该设置它，如果你这样做，你需要确保为每个组使用不同的 id。

于 2013-05-27T13:38:23.977 回答