3

这是我之前的问题如何使用 Mule 通过 REST over HTTP 上传多个文件的扩展？. 要求规定，每周三上午 10 点必须上传文件。从此以后，我需要一个调度程序来完成此任务。我发现解决方案是带有 Cron Expression 的“Quartz”入站组件。

但是我该怎么做呢？因为我不能有两个“入站端点”。（石英和文件）例如

<flow name="fileUploader" doc:name="fileUploader">

    <quartz:inbound-endpoint 
        jobName="myServiceJob" 
        repeatInterval="5000" 
        cronExpression="0 0 10 ? * WED 
        doc:name="Quartz">
        <quartz:event-generator-job/>
   </quartz:inbound-endpoint>
       
        <file:inbound-endpoint 
            path="C:\input"
            pollingFrequency="5000" moveToDirectory="C:\movehere" doc:name="File"
            responseTimeout="10000"/>
            
    <object-to-byte-array-transformer doc:name="Object to Byte Array"/>

    <file:outbound-endpoint 
            path="C:\outputfile" 
            responseTimeout="10000" 
            doc:name="File"/>

</flow>

如果我运行我会得到错误

线程“主”org.mule.module.launcher.DeploymentInitException 中的异常：SAXParseException：cvc-complex-type.2.4.a：发现以元素“文件：入站端点”开头的无效内容。

那么我需要做的改变是什么？

请帮忙

4

4 回答 4

4

试试这个

<file:endpoint name="fileConnector" path="C:\input" pollingFrequency="5000" doc:name="File"/>

<flow name="fileUploader" doc:name="fileUploader">

        <quartz:inbound-endpoint 
        jobName="myServiceJob" 
        repeatInterval="5000" 
        cronExpression="0 0 10 ? * WED" 
        doc:name="Quartz">

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

       <file:outbound-endpoint 
        path="C:\outputfile" 
        responseTimeout="10000"        
            outputPattern="#[message.inboundProperties.originalFilename]"       
       doc:name="File"/>
</flow>
于 2013-01-28T04:05:04.740 回答
2

你有两个选择：

一种。将文件入站端点替换为处理文件处理的组件。它将由 Quartz 触发，从文件夹中提取文件并将其传递给出站端点。

湾。不要使用 Quartz 端点并覆盖 org.mule.transport.file.FileMessageReceiver 来实现轮询文件的自定义调度。

第一种选择是更简单的选择。

于 2013-01-23T11:42:35.890 回答
0

如果您找不到所需的确切内容，以下只是一个工作回合。

1-您可以有 2 个流而不是 1 个，一个用于正常入站的正常工作，一个用于石英：入站端点。

2-您可以让您的调度程序将消息放在队列中，并让另一个流程从该队列中提取消息并进行处理。

3-你可以有一个带有quartz:inbound-endpoint的组件，这里建议http://blogs.mulesoft.org/using-quartz-to-trigger-a-service/

希望以上之一有所帮助。

于 2013-01-23T11:47:35.683 回答
0

抱歉，由于太长，无法将其作为评论，所以这里是<quartz:endpoint-polling-job> Mule 网站的示例：

<service name="testService5">
  <description>
  The endpoint polling Job will try and perform a 'request' on any Mule endpoint. If a result is received it will be handed off to this 'testService5' service for processing. The trigger will fire every 5 minutes starting at 2pm and ending at 2:55pm, every day. during this period the job will check the file directory /N/drop-data/in every 5 minutes to see if any event data is available. The request will timeout after 4 seconds if there are no files in the directory. 
  </description>

  <inbound>
    <quartz:inbound-endpoint name="qEP5" cronExpression="0 0/5 14 * * ?" jobName="job5"
           connector-ref="quartzConnector1">
      <quartz:endpoint-polling-job>
        <quartz:job-endpoint address="file:///N/drop-data/in" timeout="4000"/>
      </quartz:endpoint-polling-job>
    </quartz:inbound-endpoint>
  </inbound>
</service>

希望以上有所帮助

于 2013-01-24T11:19:26.020 回答