0

XML を受け取り、それをミュールで「mailQueue」として VM キュー名にポストするミュール フローがあります。xml 入力とミュール フローは次のとおりです。

<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 エンドポイントに投稿するにはどうすればよいですか? キューに書き込むのと同じフローでそれを行うことはできますか?それとも新しいフローを作成する必要がありますか? から読み取ってRestエンドポイントに送信するフローを誰かに教えてもらえますか?

事前の感謝とメリー クリスマス Y'all

4

1 に答える 1

2

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>
于 2012-12-20T22:49:27.823 に答える