問題タブ [messagebroker]

私は WSO2 MB 2.0.0 に取り組んでいます。

私の要件は、特定のトピックにメッセージを発行するための Java コードを作成することです。Message Broker でトピックを作成しました。ここで、トピックへの接続を作成し、そのトピックに関するメッセージを投稿/公開したいと考えています。

http://docs.wso2.org/wiki/display/MB200/Queue+sender+and+queue+receiverの記事に記載されている JMS を使用してキューで同じことを行いました

この点で私を助けてください。

ありがとう。

それぞれが構成可能なファイル パスを持ついくつかのトレース ノードを作成しようとしています。

メッセージブローカーの構成可能なサービスを介したものであればよいのですが、それは可能ですか? そうでない場合、それらを構成可能にする他の方法はありますか?

Websphere Message Broker を介して XML ファイルを受信しましたが、それを Java で処理すると、フォーマットされていないファイルが出力されます。

XML 入力ファイル:

Java 計算 (メッセージ処理用) :

XML 出力ファイル:

:引用符や<や>などの utf-8 文字を認識していないようなので、受信ファイルをテキストに変換すると問題が解決すると思います。しかし、それを行う方法、またはそれが最善の解決策であるかどうかはわかりません。

これについて何か考えはありますか？ありがとうございました ：）

編集:メッセージはエスケープするだけでなく、変換して出力に適切にエンコードする必要があります。

make file を使用せずに Apache qpid C++ ブローカーで helloworld の例を実行したいのですが、それは可能ですか?

Oracle DB から SFDC アカウントにデータを送信する必要があります。

シナリオ: Oracle DB -> WebSphere Message Broker (MB) -> WebSphere Message queue (MQ) -> DataPower (サービス) -> SFDC アカウント

データがどのように MB にプッシュされるかわかりませんか? MB には、任意のソースからデータをプルする機能がありますか?

その機能がない場合、データを Oracle DB から WebSphere Message Broker(MB) に移動するにはどうすればよいですか? 一般的に使用される通信プロトコルは何ですか? Oracle DB を WebSphere Message Broker(MB) に統合する方法は?

svn checkout で apache qpid をインストールしようとしていますが、make の実行中にすべてのツールをインストールしましたが、エラーが発生しました

svn co http://svn.apache.org/repos/asf/qpid/trunk

Java 計算ノードからに接続しようとしてAS400 DBいますが、エラーが発生します。あなたがアドバイスしていただけますか。

私のテストシナリオは次のとおりです。

1. ブローカ フローは 9 秒ごとにトリガーされ、行の選択と削除を実行しますAS400 DB

2. AS400 DBを使用して接続しJDBC_TransactionType.MB_TRANSACTION_AUTOます。

   try { // AS400 サーバーへの接続を取得 if (conn == null) try { conn = getJDBCType4Connection("AS400db",JDBC_TransactionType.MB_TRANSACTION_AUTO); strSelectStoredProcName = (文字列)getUserDefinedAttribute("SelectStoredProcName"); 結果 = 新しい CDBItaly_CoreSelectCustomerDetails().retrievePPWICustomerDetails(conn, strSelectStoredProcName);

   キャッチ（例外e）{}

3. 一度 ResultSet から行を取得し、正しい結果を得る - OK

4. rs.DeleterOW を使用してテーブルからすべての行を削除します。つまり、ResultSet は次回は何も返さないはずです。

5. もう一度フェッチしてみてください (これで 0 行が返されるはずです)。ただし、データベース テーブルが空であっても、手順 2 とまったく同じ行が返されます。

6. ブローカー フローを再起動すると、正常に動作します。

コードを次のように変更すると、次のようになります。

エラーが表示されます:java.sql.SQLException接続が存在しません

LMAX Disruptor についての私の理解では、LMAX Disruptorは、(正しく使用された場合) 毎秒 2000 万メッセージのスループットを可能にする恐ろしく高速で恐ろしい並行 Java コードでいっぱいの JAR であるということです。

現在、1 秒あたり 400 メッセージのオーダーで、必要なものに対して遅い ActiveMQ インスタンスがあります。LMAX を使用するようにコードをリファクタリングすることでメリットがあるかどうか疑問に思っていますが、次の懸念があります。

• 1 つのパブリッシャーと複数の (競合する) コンシューマーを持つ方法
• LMAX はメッセージをどのように保存/保管しますか? 記憶に？
• フェイルオーバー - LMAX にはフェイルオーバー プロトコル/メカニズムが用意されていますか?
• ディスク I/O - LMAX は未使用のメッセージをディスクに保持し、後でそれらを回復できますか?

そして、私がこれらすべてに完全に的外れで、LMAX ディスラプターの使用を完全に誤解しているように見える場合、誰かがそれがいつ使用されるかの具体例を提供できますか? 前もって感謝します！

ESB で作成されたプロキシによってサブスクライブされる ESB でトピックを作成しました。私のプロキシでは、WSO2 メッセージ ブローカーで作成したキューのエンドポイントを提供しました。したがって、プロキシによってサブスクライブされているキューにメッセージを発行すると、メッセージは MB のキューに送られるはずですが、これは発生していません。これを達成するにはどうすればよいですか？私のプロキシコードは次のとおりです。

トピックにメッセージを公開するときにメッセージ ブローカー キューに表示されるようにするにはどうすればよいですか?

ポート番号 9443(esb1) と 9446(esb2) で WSO2 ESB 4.6 の 2 つのインスタンスを使用し、9444 で Message Broker 2.0.1 も使用しています。この URL を使用してタスクを実行しています: http://wso2.org/ library/articles/2013/03/configuring-wso2-esb-wso2-message-broker . 上記のリンクを使用して、Queue to queue send receive の例を実行しました。そして、すべてがうまくいっています。しかし、問題は、esb1 にメッセージを投稿すると、esb2 がサブスクライバーとして機能しているため、esb2 に反映されることです。メッセージストアがesb1から渡されたメッセージを保存し、何らかのイベントに基づいて、esb1によって送信されたメッセージをesb2に提供する必要があります。前もって感謝します。マッサージ プロセッサをアクティブにすると、このエラーが継続的に発生します。