問題タブ [messagebroker]

ActiveMQ5.6からApollo1.5に切り替えようとしています。トピックのパブリッシュ/サブスクライブを使用してメッセージを交換する2つのソフトがあります。

• 最初のものはc++であり、tcpでopenwireを使用します
• 2つ目はJavascriptで、WebSocketでstompを使用します

ActiveMQを使用すると、すべてが正常に機能し、送信したメッセージは両方のソフトで読み取りと書き込みが可能であり、それ以降、クライアントを変更しませんでした。

ここで、（openwireを使用して）c ++ソフトからメッセージを送信し、JSソフトでそれらを読み取ろうとすると、エラーが発生します。実際、ヘッダーのコンテンツタイプが「protocol / openwire」のメッセージを受け取りますが、stompを期待しています。

これは私がapollo.xmlコネクタセクションを設定した方法です：

また、クライアントプロトコルを自動検出することになっているtcpおよびwsコネクタで<detect />を試してみましたが、どちらも機能しません。

誰かが私がこれを理解するのを手伝ってくれる？

ありがとうございました、

編集 ：

stompプロトコルメッセージを受信して​​いることがわかりましたが、それらは非常に奇妙な形式であり、stomp.jsがメッセージの解析に失敗してメッセージ本文を正しく埋めることができない非テキスト文字が含まれています。

これは、activemq openwireから一度受信した同じメッセージで、同じc++パブリッシャーとjsサブスクライバーでapolloopenwireを受信します。

activemq

アポロ

アポロで問題になると思いますか？

この質問は、私が以前に尋ねた質問に関連しています https://stackoverflow.com/questions/13158412/message-broker-sending-email 問題は次のとおりです: Message Broker の電子メールノードを介して電子メールを送信し、Lotus Notes クライアントは電子メールの本文を正しく表示しますが、件名が文字化けしています。件名を解析できないようで、次のように表示されます。 . Lotus Client がヘッダーを解析して正常に表示するにはどうすればよいですか? どうにかしてクライアント自体を構成するか、Email ノードを構成する必要がありますか?

Log4j を使用してさまざまな段階でステータスをログに記録する単純なメッセージ フローを開発しています。しかし、このフローを実行しようとすると、次のエラーが発生します。メッセージ フローで Log4jNode を使用しました。

''com.ibm.broker.IAM3.Log4jNode.initLog4j''ルーチン '' initLog4j ''によって参照されるJava クラスまたはメソッドを解決しようとしたときにエラーが発生しました

エラー メッセージが示すように、log4jNode の参照が見つからなかったと思います。しかし、これを突き止めることができる助けは見つかりませんでした。専門家は私を助けてください。

メッセージ Broker 7.0.0.5 で次の問題が発生しました。フローは次のとおりです。

やりたいこと: 1. XML を受け入れ、XMLNSC を使用して解析する 2. 次に、いくつかのビジネス ロジックを実行する必要がありますが、それをスキップして次のことに焦点を当てましょう - 2 つのユーザー例外をスローしたい - 1 つはモジュール内GoodReport、もう 1 つ - モジュール BadReport では、Out フローと Catch フローの両方で処理された後、メッセージがバックアウト キュー (キュー用に 1 つ作成し、しきい値を 10 に設定) に送られると想定します。再度処理するための MQInput。したがって、バックアウト キューに 10 個のメッセージがあると予想されますが、代わりに - 何も得られません

フローで両方のエラーがスローされているのを確認できますが、トレースの最後の行に最も驚かされるのは、「XMLNS」ドメインがどこから出現したのかということです。 私は XMLNSC ドメインのみを使用しています。

メッセージがバックアウト キューに表示されないのはなぜですか?

前もって感謝します！

タチアナ。

ここにトレースがあります：

2012-12-17 19:25:54.692283 5756 RecoverableException BIP2488E: ('.Esql6_1Flow_Report.Main', '19.4') SQL ステートメント''THROW EXCEPTION MESSAGE 3 VALUES ('NO_SUCH_SOURCE');'' の実行中にエラーが検出されました。メッセージ ブローカは、指定されたステートメントの実行中にエラーを検出しました。SQL プログラムを短縮するために例外がスローされました。エラーの詳細については、以下のメッセージを参照してください。

2012-12-17 19:25:54.692302 5756 ユーザー例外?????????? 3 ?????????? BIPmsgs.properties 2012-12-17 19:26:52.830982 5756 エラー BIP2628E: 入力ノード 'Esql6_1Flow.MQInput' で例外条件が検出されました。入力ノード 'Esql6_1Flow.MQInput' は、メッセージの処理中にエラーを検出しました。メッセージ・フローはロールバックされており、メッセージが作業単位で処理されていた場合は、再び処理されるために入力キューに残ります。次のメッセージは、この例外の原因を示します。後続のエラー メッセージを確認して、例外が生成された理由を特定し、それらのメッセージの説明に従って対処してください。

2012-12-17 19:26:52.831005 5756 RecoverableException BIP2230E: ノード 'Esql6_1Flow.BadReport' でメッセージを処理中にエラーが検出されました。メッセージ ブローカは、ノード 'Esql6_1Flow.BadReport' でメッセージを処理中にエラーを検出しました。メッセージの処理を短縮するために、例外がスローされました。エラーの詳細については、以下のメッセージを参照してください。

2012-12-17 19:26:52.831012 5756 RecoverableException BIP2488E: ('.Esql6_1Flow_Compute.Main', '13.4') SQL ステートメント''THROW EXCEPTION MESSAGE 3 VALUES ('NO_SUCH_SOURCE');'' の実行中にエラーが検出されました。メッセージ ブローカは、指定されたステートメントの実行中にエラーを検出しました。SQL プログラムを短縮するために例外がスローされました。エラーの詳細については、以下のメッセージを参照してください。

2012-12-17 19:26:52.831020 5756 ユーザー例外?????????? 3 ?????????? BIPmsgs.properties

2012-12-17 19:26:53.831737 5756 エラー BIP2648E: メッセージがキューにバックアウトされました。ノード「Esql6_1Flow.MQInput」。ノード 'Esql6_1Flow.MQInput' は、メッセージ フローのメイン パスで処理エラーが発生したため、以前に 1 回以上バックアウトされたメッセージを受信しました。failure ターミナルが接続されていないため、メッセージ ブローカは、このノードに関連付けられた再キューまたはデッド レター バックアウト キューにメッセージを直接入れています。メッセージの MQMD 'backoutCount' は、WebSphere MQ 入力キューに定義された 'backoutThreshold' と等しくなりました。以前のメッセージとメッセージ フローを調べて、メッセージがバックアウトされている理由を判断してください。可能であれば、この状況を修正してください。

2012-12-17 19:26:53.832435 5756 UserTrace BIP2638I: MQ 出力ノード 'Esql6_1Flow.MQInput' が、キュー マネージャー ''testQueueManagerName'' に接続されているキュー ''SYSTEM.DEAD.LETTER.QUEUE'' にメッセージを書き込もうとしました. MQCC は「0」で、MQRC は「0」でした。

2012-12-17 19:26:53.832466 5756 UserTrace BIP2615I: WebSphere MQ 入力ノード 'Esql6_1Flow.MQInput' がメッセージをバックアウト リキューまたは送達不能キューにバックアウトしました。メッセージのバックアウト処理が呼び出されました。メッセージは、WebSphere MQ キュー マネージャーおよびキュー構成によって決定されるように、バックアウト リキューまたはデッド レター キューに書き込まれることによってバックアウトされました。ユーザーの操作は不要です。

2012-12-17 19:27:31.087949 4380 UserTrace BIP2632I: メッセージが受信され、MQ 入力ノード '.InputNode' の 'out' ターミナルに伝搬されました。

2012-12-17 19:27:31.088045 4380 UserTrace BIP6060I: ノード '.InputNode' に代わって作成されたパーサー タイプ ''Properties'' は、オフセット '0' で始まる長さ 0 バイトの着信メッセージの部分を処理します。

2012-12-17 19:27:31.088066 4380 UserTrace BIP6061I: ノード「.InputNode」に代わって作成されたパーサー タイプ「MQMD」は、オフセット「0」で始まる長さ「364」バイトの着信メッセージの部分を処理します。前のパーサーからの値 ''MQHMD'' に基づいて選択されたパーサー タイプ。

2012-12-17 19:27:31.088092 4380 UserTrace BIP6069W: ブローカーは、データ・タイプ「」のメッセージを処理できません。メッセージ ブローカは、タイプ「」のデータの処理を必要とするメッセージを受信しましたが、ブローカには、このタイプのデータを処理する機能がありません。メッセージ・ブローカーに送信されているメッセージとノードの構成データの両方を確認してください。メッセージがブローカーによって処理される場合は、サポートされていないデータ型への参照を削除する必要があります。

2012-12-17 19:27:31.088113 4380 UserTrace BIP6061I: ノード「.InputNode」に代わって作成されたパーサー タイプ「XMLS」は、オフセット「364」で始まる長さ「236」バイトの着信メッセージの部分を処理します。前のパーサーからの値''XMLS''に基づいて選択されたパーサー タイプ。

メッセージセットを使用してファイルを解析していますが、次の例外が発生します。実際の意味を理解できません。問題の理解と解決にご協力ください。

ws-event デモ q1 に関するメッセージ ブローカー: http://wso2.org/library/knowledge-base/2012/06/publishing-messages-message-broker-using-event-mediator

クライアントがプロキシサービスを呼び出す方法

q2: イベント シンク URL ターゲット サービスのデモ

Web サービスとして公開されているメッセージ フローがあります。そのフローでは、別の Web サービスを呼び出しています。フローは、ほとんどの場合、wsdl をメッセージ セットから IBM Websphere Message Broker Tool Kit のデザイナーにドラッグすることによって生成されます。これが私のフローです：

SoapInput--> SubFlow to Expose Service--> Subflow to invoke Service-->SoapReply

SubFlow to Expose ServiceWSDLをドラッグして「サービスとして公開」を選択すると生成されます。

Subflow to invoke ServiceWSDLをドラッグして「サービスとして呼び出す」を選択すると生成されます。

サービス エンドから無効なパラメータ エラーを取得しています。呼び出そうとしたすべてのサービスで同じエラーを受け取っていません。これは、1 つのサービスでのみ発生します。フローに何か問題がありますか?

kafka 0.7 では、プロデューサーに zk.connect を指定できるため、プロデューサーはブローカーの追加と削除を見つけることができます。しかし、kafka 0.8 では、プロデューサーに zk.connect を指定できません。kafka 0.8 のプロデューサーはそれを見つけることができますか? そうでない場合、システムのスケーラビリティは 0.7 バージョンよりも悪くありませんか?

Message Broker 7.0 と MQ 7.0 を使用して単純な pub/sub フローを開発する際の助けをいただければ幸いです。

私のフローは、ヘッダーのない特定のメッセージを受け入れ、フィールドに基づいてフィルター処理することになっています (値が "yes" の場合はプロセス) そして、メッセージのノードにリストされているすべてのキューに本文を発行します

これが私の流れです：

MQ にトピックとサブスクリプションを登録しましたが、次に何をすればよいかほとんどわかりません。ポイントツーポイント アプリケーションのテストに RFHUtil を使用しましたが、パブリッシュ/サブスクライブの開発中にそれを使用する方法がわかりません。

質問: 1. パブリッシャーとして単純なキューを使用するのは正しいですか (MQ 入力では、MQ にあるキューを「IN」に設定するだけです) 2. このフローでサブスクライバー/複数のサブスクライバーを登録するにはどうすればよいですか? サブスクリプションポイントとは何ですか？

それは単なる学習課題です。

どんな助けでも大歓迎です！

構成可能なサービス (CDServer) があります。構成可能サービスを使用している CDInput ノードを使用する WMB フローをデプロイしようとすると、次のエラーが発生しました。

ファイル パスは、Windows エクスプローラーからアクセスできます。フォルダー「myfolder」は、リモート コンピューターで共有されます。

どこでエラーが発生するかわかりません。ファイル パスを別の形式 (192.168.45.91\myfolder) に変更しようとしましたが、それでもうまくいきません。

私は使用しています：

WMB 8.0.0.1 MQ 7 スターリング コネクト ダイレクト 4.6

この問題に関するヘルプは大歓迎です。