从 Mule 中的 vm 队列发布到 REST 端点

Question

我有一个 mule 流，它接受一个 xml 并将其发布到一个 vm 队列，名称为 mule 中的“mailQueue”。 xml输入和mule流程如下：

<Mail>
  <Name>JonHender</Name>
  <Age>16</Age>
</Mail>

---

Mule_config.xml：

 <!-- This is the persistent VM connector -->
           <vm:connector name="mailQueueConnector" queueTimeout="1000">
                 <vm:queue-profile>
                <file-queue-store />
                 </vm:queue-profile>
           </vm:connector>


            <flow name="MailService">
                <https:inbound-endpoint address="https://localhost:71234/message/email"
                    method="POST"
                    exchange-pattern="request-response"
                    contentType="application/xml"/>

                <vm:outbound-endpoint path="mailQueue" connector-ref="mailQueueConnector">
                    <message-property-filter pattern="http.status=200" />
                    <logger message="INTO mailQueue" level="INFO"/>
                </vm:outbound-endpoint>

            </flow>

现在，我必须读取此“mailQueue”并将其发布到 REST 端点 (https://localhost:71234/messages/sendemail)。我尝试在同一流程中添加它，但没有用

<inbound>
    <vm:inbound-endpoint address="vm://emailBufferQueue" exchange-pattern="one-way" connector-ref="emailQueueConnector" />
</inbound>
<outbound>
    <https:outbound-endpoint address="https://localhost:71234/messages/sendemail"
</outbound>

如何从 vm 队列中读取数据并将其发布到 REST 端点？我可以在我写入队列的同一流程中执行此操作，还是应该创建一个新流程？有人可以向我展示从 the 读取并将其发送到 Rest 端点的流程吗？

提前谢谢大家，圣诞快乐

Answer 1

在另一个流程中使用mailQueue：

<flow name="MailSender">
    <vm:inbound-endpoint path="mailQueue"
                         exchange-pattern="one-way"
                         connector-ref="mailQueueConnector" />
    <https:outbound-endpoint
           address="https://#[message.inboundProperties.username]:#[message.inboundProperties.password]@localhost:71234/messages/sendemail" />
</flow>