問題タブ [wso2mb]

現在 WSO2 Message Broker を使用していますが、ESB を使用せずにこの製品を WSO2 BPS に接続する必要があります。だから私の質問は、そうすることが可能ですか? または、WSO2 ESB を使用して MB を BPS と統合する必要がありますか?

wso2mb を wso2esb と統合し、永続的なトピックを使用して、サブスクライバーがアクティブでないときにメッセージをキューに保持し、将来それらを回復しようとしています。wso2mb ドキュメントの統合の最初の方法 (JMS エンドポイントと JMS プロキシ サービスを使用した統合) を使用しました。ここに私のパブリッシャープロキシがあります:

この回答を使用して、コンシューマー プロキシと永続的なトピックを作成しました。これが私のサブスクライバー プロキシです。

SoapUI を使用してパブリッシャー プロキシを呼び出すことができ、サブスクライバー プロキシはメッセージを消費して SimpleStockQuoteService (wso2esb サーバー サンプル) に送信しますが、サーバーをシャットダウンするとメッセージがトピック キューに蓄積され、サーバーを再起動するまでに問題が発生します。サブスクライバーは消費せず、蓄積されたメッセージをサーバーに送信しません。wso2esb なしで wso2mb を使用し、Java コードを使用して JMS クライアント サブスクライバーを使用すると、永続的なトピックは完全に機能し、サーバーの起動後にメッセージを消費します。何か案は？

このリンクをたどろうとしましたが、最初の 3 回はブローカーとして WSO2 MB を使用し、最後に Apache ActiveMQ を試しましたが、SimpleQuoteService サーバーをシャットダウンしたときに問題が発生しました。 SoapUI 経由でプロキシにメッセージを送信すると、メッセージはキューに蓄積され、スケジュールされたメッセージ転送プロセッサは最大配信試行回数に達すると非アクティブになりますが、WSO2-ESB のドキュメントには次のように書かれています。元のメッセージ ストア) を作成し、いくつかのメッセージをプロキシ サービスに送信します。元のメッセージ ストアが使用できないため、メッセージがバックエンドに送信されていないことがわかります。また、メッセージがフェイルオーバーに格納されていることもわかります。メッセージストア。」

説明してくれる人いますか?!!!!

私のプロジェクトでは、WSO2 Message Broker をメッセージ ブローカー システムとして使用しています。

作成されたキューの数、キュー内のメッセージの数などの情報を取得して、ポータルに表示したいと考えています。これを行うには、Java クラスでメッセージ ブローカー API を呼び出します。

Java クラスでメッセージ ブローカー API を呼び出すことはできますか? はいの場合、Java コードで使用できる API のリストはどこで入手できますか?

私のプロジェクトでは、wso2 メッセージ ブローカーをメッセージ ブローカー システムとして使用しています。wso2 メッセージ ブローカーを使用する前に、wso2 メッセージ ブローカーのキュー/トピックに関連する例外的なケースを調べたい -

1. コンシューマーがダウンし、パブリッシャーがキュー/トピックにメッセージを継続的に送信している場合、キュー/トピックに保存できるメッセージの数は?

2. キュー/トピックが利用できず、パブリッシャーがキュー/トピックにメッセージを投稿しようとするとどうなりますか?

3. 保存できるメッセージ キュー/トピックの最大サイズは? 設定可能ですか？

4. wso2 メッセージ ブローカーの JSON メッセージ形式は何ですか?

5. キュー/トピックからメッセージを取得した後、コンシューマーはパブリッシャーに応答を送信できますか? はいの場合、どのように？

6. キュー/トピック セッション タイムアウトの期間は? 設定可能ですか？

2 つのキューを作成MyFirstQueueしMySecondQueue、wso2 メッセージ ブローカーに作成しました。hereのサンプル アプリケーションを使用して、メッセージを発行および使用でき ます。

wso2AndesAdminServiceクラスを使用して、作成されたキューの数、各キュー内のメッセージの数、パージ キューなどのキュー関連情報をコードで取得したいと考えています。

AndesAdminServiceコードにクラスを導入するにはどうすればよいですか? そして、他にどのような瓶が必要になるでしょうか?

私は自分のプロジェクトに次のjarファイルを持っています:

1. andes-client-3.1.1.jar
2. geronimo-jms_1.1_spec-1.1.0.wso2v1.jar
3. log4j-1.2.13.jar
4. org.wso2.carbon.logging-4.4.1.jar
5. org.wso2.securevault-1.0.0-wso2v2.jar
6. slf4j-1.5.10.wso2v1.jar

サンプルコードも教えてください。

ここでAndesAdminService クラスのコードを取得しました。

私のプロジェクトでは、WSO2 Message Broker をメッセージ ブローカリング システムとして使用しています。キュー情報 (wso2mb サーバーで作成されたすべてのキューの取得、各キュー内のメッセージ数などの情報) を取得するために、AndesAdminServics WSDL からクライアントを生成し、API から getAllQueues() API を呼び出してみました。要求されたターゲット例外への有効な証明書パスを見つけることができなくなるたびに。何が問題なのかわかりません。例外は -

getAllQueues() メソッドを呼び出すための私の API は -

wso2 esb で json を json に変換する際に問題があります。実際には、プロキシでペイロード ファクトリを使用しており、残りと json のコンテンツでプロキシを呼び出します。これが私の統合フローです。私はプロキシを呼び出し、プロキシはリクエストを(jsonコンテンツとともに)jmsメッセージストアに送信します。次に、メッセージプロセッサを定義して、メッセージストアからメッセージを消費し、定義されたエンドポイント(.net web)に送信しますAPI)。しかし問題は、数値を含む文字列が自動的に整数要素として変換されることです: "orderId": 10000 (文字列 "orderId": "10000" にしたい) ですが、プロキシからエンドポイントにリクエストを直接送信すると (なしで)メッセージ ブローカを使用する場合)、正常に動作します。この問題を解決するのを手伝ってくれませんか?

WSO2 Message Broker v3.1 のドキュメントでは、「Stratos Message Broker - Dashboard UI Features」と呼ばれる ESB 機能として Message Broker を使用できることが示唆されています:ここから

MB を最新の WSO2 ESB バージョン (v4.9) に機能としてインストールしようとしています。

そのために、最新の P2 リポジトリを使用しています: ここから

「Stratos Message Broker - Dashboard UI Features」v 3.1 を選択すると、次のエラー メッセージが表示されます。

MBの最新版をESB Featureとして使えないということでしょうか？私は他の人を試しましたが、成功しませんでした..

リポジトリ: WSO2 Carbon 4.2.0 (Turing) - MB バージョン: 2.2.0 - エラー メッセージ:

リポジトリ: WSO2 Carbon 4.1.7 - MB バージョン: 2.1.1 - エラー メッセージ:

なにか提案を？ すでに MB を ESB 機能として使用している人はいますか? どのバージョン？

ありがとう！