quartzendpoint和文件到字符串转换器出现以下异常

Question

java.lang.IllegalArgumentException: Cannot apply transformer FileToString{this=2e93ba04,
name='File_to_String', ignoreBadInput=false, 
returnClass=SimpleDataType{type=java.lang.String, mimeType='*/*'}, 
sourceTypes=[SimpleDataType{type=java.io.File, mimeType='*/*'}, 
SimpleDataType{type=java.io.FileInputStream, mimeType='*/*'}]}
on source payload: class org.mule.transport.AbstractConnector$7.

以下是我们代码的片段。

<quartz:inbound-endpoint responseTimeout="10000"
            doc:name="Quartz" cronExpression="0 0/3 * * * ? *" repeatInterval="0"
            jobName="ApptioStart" >
            <quartz:endpoint-polling-job>
                <quartz:job-endpoint ref="fileConnector"/>
            </quartz:endpoint-polling-job>

        </quartz:inbound-endpoint>
        <logger message="#[message.outboundProperties]" level="INFO" doc:name="Logger"/>

        <!-- Read file from predefined folder path <file:inbound-endpoint path="${csv.folder.path}" 
            responseTimeout="10000" doc:name="File" /> -->
        <file:file-to-string-transformer
            doc:name="File to String" />

Answer 1

问题就在这里：

<quartz:job-endpoint ref="fileConnector"/>

ref 应该引用全局终结点，而不是连接器。这就是为什么消息的有效负载是 org.mule.transport.AbstractConnector，这会导致异常。

因此，通过将其置于流之外来创建全局文件endpoint：

<file:endpoint name="csvFileEndpoint"
      path="${csv.folder.path}" 
      responseTimeout="10000"
      doc:name="CSV Files" />

然后在Quartzendpoint中使用它：

<quartz:job-endpoint ref="csvFileEndpoint"/>

引用：

• https://developer.mulesoft.com/docs/display/current/Quartz 传输引用#QuartzTransportReference-EndpointPollingJob
• https://github.com/mulesoft/mule/blob/mule-3.6.2/transports/quartz/src/test/resources/quartz-polling-functional-test.xml#L34