3

我想使用 Mule 来移动和处理文件。我正在尝试使用流和“所有路由器”将相同的文件移动到不同的文件夹，但它失败了。

这有效：

    <flow name="testflow2Flow1" doc:name="testflow2Flow1">
    <file:inbound-endpoint path="C:\IN" fileAge="10000" responseTimeout="10000" doc:name="File"/>
    <set-variable variableName="tempfilename" value="#[header:originalFilename]" doc:name="Variable"/>
    <file:outbound-endpoint path="C:\OUT" responseTimeout="10000" doc:name="File"/>
</flow>

在此处输入图像描述

但是这个不行！

    <flow name="testflow2Flow1" doc:name="testflow2Flow1">
    <file:inbound-endpoint path="C:\IN" fileAge="10000" responseTimeout="10000" doc:name="File"/>
    <set-variable variableName="tempfilename" value="#[header:originalFilename]" doc:name="Variable"/>
    <all doc:name="All">
        <processor-chain>
            <file:outbound-endpoint path="C:\OUT" responseTimeout="10000" doc:name="File"/>
        </processor-chain>
    </all>
</flow>

在此处输入图像描述

我得到这个例外：

INFO 2013-10-03 20:22:19,072 [[testflow2].connector.file.mule.default.receiver.01] org.mule.transport.file.FileMessageReceiver：在文件中获得锁定：C:\IN\test。 txt.txt 错误 2013-10-03 20:22:19,088 [[testflow2].testflow2Flow1.stage1.02] org.mule.exception.DefaultMessagingExceptionStrategy：

消息：无法使用流有效负载复制消息。有效载荷类型是“org.mule.transport.file.ReceiverFileInputStream”。消息有效负载的类型：ReceiverFileInputStream

代码：MULE_ERROR--2

Exception stack is: 1. Cannot copy message with a stream payload. Payload type is "org.mule.transport.file.ReceiverFileInputStream". Message payload is of type: ReceiverFileInputStream (org.mule.api.MessagingException)

org.mule.routing.outbound.AbstractSequenceRouter:74 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/MessagingException.html)

Root Exception stack trace: org.mule.api.MessagingException: Cannot copy message with a stream payload. Payload type is "org.mule.transport.file.ReceiverFileInputStream". Message payload is of type: ReceiverFileInputStream at org.mule.routing.outbound.AbstractSequenceRouter.route(AbstractSequenceRouter.java:74) at org.mule.routing.outbound.AbstractOutboundRouter$1.process(AbstractOutboundRouter.java:105) at org.mule.routing.outbound.AbstractOutboundRouter$1.process(AbstractOutboundRouter.java:100) + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything)

4

2 回答 2

4

Adding this <object-to-byte-array-transformer/> transformer after your inbound endpoint will make it work.

<flow name="testflow2Flow1" doc:name="testflow2Flow1">
    <file:inbound-endpoint path="C:\IN" fileAge="10000" responseTimeout="10000" doc:name="File"/>
    <object-to-byte-array-transformer/>
    <set-variable variableName="tempfilename" value="#[header:originalFilename]" doc:name="Variable"/>
    <all doc:name="All">            
        <file:outbound-endpoint path="C:\OUT" responseTimeout="10000" doc:name="File"/>
        <file:outbound-endpoint path="C:\OUT1" responseTimeout="10000" doc:name="File"/>        
    </all>
</flow>

I think why it failed is because mule was trying to read file as stream and write as stream; which was fine in your 1st case.

但是在第二个流程中，因为您想写入多个地方，所以流式传输是不可能的。添加此转换器后，现在您在内存中拥有完整的有效负载，并且可以写入多个。

于 2013-10-03T18:29:58.547 回答
0

您需要将 InputFileStream 转换为字节数组。设置一个全局转换器（转到文件连接器属性--> 转换器--> 添加）。选择文件到字节数组选项。连接器配置将如下所示。

file:inbound-endpoint path="C:\File Input" responseTimeout="10000" transformer-refs="File_to_Byte_Array" doc:name="File"/>

InputFileStream 您不能将其复制到变量中。

于 2017-09-12T06:04:09.860 回答