1

问题陈述是并行执行多项操作并聚合响应并将其存储在文件中。

链接到工作室中的骡流图像： 图像

在这个流程中，我试图做的是在 scatter 和 collect 的两个分支中设置两个常量字符串，然后聚合并存储在文件中。我尝试用“我的响应”用“设置有效负载”覆盖有效负载。我期待“我的回应”作为文件的内容。但是文件内容是：

¨Ìsr)java.util.concurrent.CopyOnWriteArrayListx]ü'F´ê√xpwtmsg 1tmsg 2x

我进行了调试，文件端点的有效负载是“我的响应”。集合如何以及为什么被写入文件。

谁能帮我让它工作。以下是xml：

<flow name="mule-assignFlow21123">
        <quartz:inbound-endpoint jobName="dummyflow" repeatInterval="10000" responseTimeout="10000" doc:name="Quartz">
            <quartz:event-generator-job/>
        </quartz:inbound-endpoint>
        <scatter-gather doc:name="Scatter-Gather1" >
            <threading-profile maxThreadsActive="1" poolExhaustedAction="RUN"/>
            <processor-chain>
                <set-payload value="msg 1" doc:name="Set Payload"/>
                <logger level="INFO" doc:name="Logger"/>
            </processor-chain>
            <processor-chain>
                <set-payload value="msg 2" doc:name="Set Payload"/>
                <logger level="INFO" doc:name="Logger"/>
            </processor-chain>
        </scatter-gather>
        <set-payload value="my response" doc:name="Set Payload"/>
        <file:outbound-endpoint path="/Users/premkumar/Desktop" outputPattern="Results.txt" responseTimeout="10000" mimeType="text/plain" doc:name="Save 2 File"/>
    </flow>

4

1 回答 1

1

由于石英端点，流程将自动确定processingStrategy飞行中的事件，该事件将是异步的，因此文件端点也将触发异步。

而是将流显式设置processingStrategy为synchronous：

<flow name="mule-assignFlow21123" processingStrategy="synchronous">
<quartz:inbound-endpoint jobName="dummyflow" repeatInterval="10000" responseTimeout="10000" doc:name="Quartz">
    <quartz:event-generator-job/>
</quartz:inbound-endpoint>
<scatter-gather doc:name="Scatter-Gather1" >
    <threading-profile maxThreadsActive="1" poolExhaustedAction="RUN"/>
    <processor-chain>
        <set-payload value="msg 1" doc:name="Set Payload"/>
        <logger level="INFO" doc:name="Logger"/>
    </processor-chain>
    <processor-chain>
        <set-payload value="msg 2" doc:name="Set Payload"/>
        <logger level="INFO" doc:name="Logger"/>
    </processor-chain>
</scatter-gather>
<set-payload value="my response" doc:name="Set Payload"/>
<file:outbound-endpoint path="/Users/premkumar/Desktop" outputPattern="Results.txt" responseTimeout="10000" mimeType="text/plain" doc:name="Save 2 File"/>

于 2015-11-20T15:23:38.133 回答