聚合时收到重复消息：mule esb

Question

在合并多个文件时遇到问题。我存储两个不同的文件。并将这两个文件合二为一。有时我收到重复的消息。或者某个时候一个文件丢失了。 以下是我的流程

<flow name="CombineFiles" >
        <file:inbound-endpoint path="Custom" responseTimeout="10000" doc:name="File" moveToDirectory="BackUp"/>
        <file:file-to-string-transformer doc:name="File to String"/>
        <scripting:component doc:name="Groovy">
            <scripting:script engine="Groovy"><![CDATA[long now = new java.util.Date().getTime(); 
                long mod = now % 2000; 
                message.setCorrelationId(String.valueOf(now - mod));
                message.setCorrelationGroupSize(100);
                return message;
            ]]></scripting:script>
        </scripting:component> 

        <collection-aggregator  failOnTimeout="false" doc:name="Collection Aggregator" timeout="3000"/>
        <combine-collections-transformer doc:name="Combine Collections"/>
        <logger message="FINAL #[payload]" level="INFO" doc:name="Logger"/>
        <object-to-string-transformer doc:name="Object to String"/>
        <file:outbound-endpoint path="Result" outputPattern="result1" responseTimeout="10000" doc:name="File"/>

    </flow> 

有时我两次收到来自 file1 的消息。或者有一段时间只收到 1 条文件消息。我想合并2个文件。我的流程有什么问题？？？

Answer 1

就在<combine-collections-transformer/>之后放

 <set-payload value="#[message.payload[0]] #[message.payload[1]]" doc:name="Set Payload"/>

并检查您的问题是否得到解决。我在这里尝试的是从集合聚合器显式设置您的消息... 但请注意，如果有超过 2 个文件，这可能不起作用.. 但由于您的要求是在这里使用 2 个文件作为输入.. 这会很好用