Mule と JMS は初めてです。コネクタを使用して JMS エンドポイントを追加する方法を理解しようとしています。Mule によって提供される JMS 実装はありますか、それとも外部 JMS プロバイダーを使用する必要がありますか?
3 に答える
簡単な例は次のとおりです:-
<jms:activemq-connector name="Active_MQ" brokerURL="tcp://localhost:61616" validateConnections="true" doc:name="Active MQ"/>
キューにメッセージを送信するには:-
<flow name="JmsSendFlow" doc:name="JmsSendFlow" >
<http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8082" path="mainData" doc:name="HTTP"/>
<set-payload value="Test Data" />
<jms:outbound-endpoint queue="StudioOUT" connector-ref="Active_MQ" doc:name="JMS"/>
</flow>
キューからメッセージを受信するには:-
<flow name="JmsReceiveFlow" doc:name="JmsReceiveFlow" >
<jms:inbound-endpoint queue="StudioOUT" connector-ref="Active_MQ1" exchange-pattern="one-way"/>
<logger message="Message received#[message.payload]" level="INFO" doc:name="Logger"/>
</flow>
JMS の詳細については、http: //blogs.mulesoft.com/dev/newbie/mule-school-jms-tutorial/を参照してください。
Mule JMS コネクタの ActiveMQ 使用ガイドは次のとおりです。
Mule ActiveMQ 統合 http://www.mulesoft.org/documentation/display/MULE3USER/ActiveMQ+Integration
これは役立つはずです。
別の HTTP コネクタをドラッグしてキャンバスにドロップし、新しいフローを作成します。フローに postTopicMessageFlow という新しい名前を付けます。「HTTP プロパティー」ビューで、コネクター構成を既存の HTTP_Listener_Configuration に設定します。パスを /jms に設定し、許可されるメソッドを GET に設定します。別の JMS コネクタをドラッグして、フローのプロセス セクションにドロップします。「JMS プロパティー」ビューで、トピックを選択し、それを jms 接続に設定します。コネクタ構成を既存の Active_MQ に設定します。Attribute 'action' is required という警告が表示された場合は、無視してください。HTTP と JMS コネクタ エンドポイントの間に Set Payload トランスフォーマを追加します。[Set Payload Properties] ビューで、表示名を [Set Message] に変更し、値をメッセージ クエリ パラメータに設定します。Set Payload トランスフォーマーにブレークポイントを追加します。Set Payload トランスフォーマーの後に Property トランスフォーマーを追加します。[プロパティ] ビューで、表示名を [セット名] に変更します。[プロパティの設定] を選択し、名前を name に、値を自分の名前に設定します。注: 必要に応じて、これを代わりにクエリ パラメータに設定できます。ファイルを保存してアプリケーションを再デプロイし、 http://localhost:8081/jms?message=こんにちは。コンソールを見ると、あなたの名前とメッセージがクラスメートの名前と一緒に表示されているはずです。