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