0

ActiveMQ 5.8 をインストールし、いくつかの内部キューを作成しました。次に、最初のキュー (inbound.A) から他の内部キュー (B、A、D など) にメッセージを再ルーティングするキャメル ルートを作成しました。

次の部分は、HTTP URL にメッセージを投稿する Web サービスから xml を受信するように ActiveMQ を構成することです。いくつかの例を取得しようとしましたが、バンドルされているデモはどれも機能していません。

webapps/api/ フォルダーには何もないことがわかります。webapps-demo/demo フォルダーを調べても、これを行う方法や同様の方法の例はありません。

私がする必要があることを概説しました：

  1. 最初に、プロデューサー Web サービスがアクセスできる URL を公開します。これは、トランスポート コネクタを更新するだけで簡単に実行できますか? 

    

<transportConnectors>
    <transportConnector name="openwire" uri="tcp://0.0.0.0:61617?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600"/>
    <!--<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600"/>-->
</transportConnectors>

  2. 次に、この URL に投稿されたメッセージが inbound.A キューに到達するように、このエンドポイントを構成する必要があります。

誰かが私が見ることができる例を提案できますか?

4

1 に答える 1

0

XML メッセージを ActiveMQ キューにポストする必要がある場合は、camel-jettyを使用してインバウンド HTTP エンドポイントを公開し、このように XML をテキストとしてキューに直接送信します...

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
    <route id="InboundHTTPRoute">
        <from uri="jetty:http://0.0.0.0:8080/inbound/"/>
        <inOnly uri="activemq:inboundQ?jmsMessageType=Text"/>
    </route>
</camelContext>

それ以外の場合、HTTP SOAP インターフェースを定義する必要がある場合は、camel-cxfを使用してください。

于 2013-10-17T02:39:56.607 に答える