問題タブ [mq]

この記事を読みました

そして、トピックが MQ でどのように機能するかという概念をまだ理解していませんでした。JMS では、トピックにメッセージを発行できることを知っています。トピックからメッセージを受信するには、まずトピックにサブスクライブする必要があります (受信フェーズでサブスクリプション名を使用)。

MQ でどのように機能しますか? （JMSのように）簡単なシナリオを書きたい：

実稼働環境で WebSphere キュー マネージャーを作成しようとしています。この前に、問題なく開発環境でキューマネージャーを作成できました。

このスクリプトを使用して、キュー マネージャーを作成しています。

crtmqm -u SYSTEM.DEAD.LETTER.QUEUE test1.qm

しかし、応答はありません (エラーまたは成功メッセージはありません)。キュー マネージャーを起動しようとすると ( strmqm test1.qm)、

「AMQ8118: WebSphere MQ キュー マネージャーが存在しません。」

それから、起こるはずのない多くの奇妙なことに気づきます。

1. エラーなしで「crtmqm -u SYSTEM.DEAD.LETTER.QUEUE test1.qm」を数回実行できます

2. crtmqm と入力するだけで応答がありません

3. crtmqm -y と入力できます (-y 引数がないため、これは不可能です)。それでも応答がありません。

誰が何が悪いのか教えてもらえますか?

私は次のことをしようとしています：

バックグラウンドサービスを作成するMQTTブローカーからinputQueueでメッセージを受信したときにポップアップを表示する

だから私はmqttブローカーへのサブスクリプションがうまく機能しています。メッセージが到着すると、ポップアップを表示するインテントが開始されますが、次のエラーが表示されます。

キューは5秒ごとにチェックされ、次のような項目がある場合はポップアップの開始アクティビティを発行します

SMSPopupクラスは次のようになります。

リポジトリでMercurialQueuesを使用していて、それらのパッチをパッチリポジトリに配置しました。別の寄稿者が私のパッチキューのクローンを作成し、独自の変更を加えました。ここで、ローカルパッチリポジトリでそれらの変更をマージしたいと思います。

このマージを実行するための適切なワークフローを見つけようとしています。

• パッチリポジトリの履歴に寄稿者の変更セットを反映します
• 競合が発生した場合にユーザーのマージツールを呼び出します

最初は、パッチを直接マージしようとしました。これは非常に単純なケースでは問題ありませんが、パッチは行番号のコンテキストに依存しているため、多くのことが変更された場合はうまく機能しません。全体として、パッチの3方向の差分を調べるのは複雑すぎると思います。

もっと良い方法はありますか？

私は今、これについてしばらくの間、ぐるぐる回っています。提供されたチャネル テーブル ファイルを使用して、分散キュー マネージャーに接続しようとしています。サーバーで環境変数 MQCHLLIB と MQCHLTAB を指定すると、これを機能させることができます。ただし、IBM のドキュメントには、.net 構成ファイルがこれらの変数をオーバーライドできると記載されています。

これが私のweb.configファイルに入れたものです：

そして、実行中のコードは次のとおりです。

queueManagerName は、汎用キュー マネージャ「*Q101T」に設定されます。

ただし、これは機能せず、次のエラーが返されます: 2058 MQRC_Q_MGR_NAME_ERROR

環境変数以外にこれを機能させる方法に関するドキュメントを見つけることができませんでした。標準の mqclient.ini は、web.config のチャネル スタンザによってオーバーライドされる必要があります。

コードで見逃したものはありますか? どんなヒントでも大歓迎です。

編集: connectionType を MQC.TRANSPORT_MQSERIES_MANAGED に変更しましたが、取得していたエラーを回避しています。ただし、I/O エラーが返されるようになりました。

System.IO.IOException はユーザー コードによって処理されませんでした Message="I/O エラーが発生しました。" Source="amqmdnet"
StackTrace: IBM.WMQ.MQChannelTable.CreateChannelEntryLists(MQChannelListEntry nameList) で

これはhttps://www-304.ibm.com/support/docview.wss?uid=swg1IC69174に関連している可能性が最も高いと思うので、ミドルウェア担当者がこれに該当するかどうかを確認し、できれば提供してくれるのを待っています新しい .TAB ファイルで...

Edit2 これは問題ではないようです。MQ トレースを実行しましたが、AMQCLCHL.TAB ファイルが見つからないためにエラーが発生しています。なぜまだこのファイルを探しているのかわかりません。web.config で指定されたチャネル テーブルを使用する必要があります。これらの値を取得しない理由を知っている人はいますか?

MDB を使用した MQ キューの JMS バインディングでこの奇妙な問題が発生しました

メッセージ駆動型 EJB:CrbEventMessageAsynchronousServiceは JMS 送り先に接続できません: queue.contratto.crb.input.publicQueue。エラーは次のとおりです。

javax.jms.JMSException: MQJMS1017: 非ローカル MQ キューは、受信またはブラウジングには無効です>

を確認したところQueueManager、mq キューはローカルとして定義されており、例外で述べられているようにリモートではありません。

サーバーからのデータに対して同期要求/クエリを実行する必要があるモバイル アプリケーションがあるとします。リクエストは最初にホストされた JMS クライアントに送信され、外部キューに (パートナーから) メッセージ/リクエストが発行されます。ここで、不明確になり始めます。同期方式でパートナーから応答を返すにはどうすればよいですか。

• パートナーは、サブスクライブするために別のキューを公開し、その別のキューから応答メッセージを取得するまでモバイル リクエストをブロックする必要がありますか?
• JMS または独自の WebSphere MQ インターフェースは、同期メッセージングをサポートしていますか?
• メッセージングでそれを実装する他の方法は何ですか?

ありがとう

私はDaleLaneのブログをフォローして、AndroidプロジェクトからMosquittoにアクセスしていますが、最初のステップで立ち往生しています。ログの関連部分は次のとおりです。

例外は、Daleのコードの「connectToBroker（）」メソッドでスローされます。

クライアントと同じマシンでMosquittoブローカーを実行しています。サンプルで提供されているIA92クライアントを介してブローカーをパブリッシュ/サブスクライブできます。また、同じサービスパラメーターを使用して単純なJavaプロジェクトを介して接続することもできます。

どうもありがとう ！

N子プロセスが親プロセスからフォークされ、これらの子にメッセージを送信し、子が互いにメッセージを送信するように、UnixでCアプリケーションを作成することになっています。

ただし、問題は、特定のターゲット子プロセスにメッセージを送信する必要があることです。つまり、親は子1に送信し、子1は子2に送信し、...および子nは1（循環的に）送信します。

問題は、メッセージキューを1つだけ作成すると、n子のいずれかがメッセージをデキューする可能性があるため（カーネルスケジューラが原因で親プロセスの後に実行される可能性があるため）、メッセージが間違ったプロセスでデキューされることです。

私のアプリケーションでは、最大になります。一度に1つのメッセージがキューにあります。唯一の解決策はn、特定のターゲットプロセスがメッセージを受信できるように、さまざまなメッセージキューを作成し、メッセージを適切なキューに渡すことです。しかし、もっと正当な解決策が必要だと思います。

何か案は？

制約：プロセス間のパイプは許可されていません。ここではmqが非効率的であることを私は知っています。それらも実装します。両方とも必須です。PSこれはちょっとした宿題です（私はhttp://canyoudomyhomework.comの作成者です）が、これは単なる宿題ではなく、難しい質問です。

簡略化されたバージョンの例を使用して、探しているものを最もよく説明できます。Tornadoのデモの1つは、単純なチャットサーバーです。

https://github.com/facebook/tornado/blob/master/demos/chat/chatdemo.py

MessageMixinここの授業に興味があります。メッセージの静的な長さのバックログを保持し、新しいメッセージが利用可能になると、新しいメッセージリストのスライスを返します。またはそれはそれがするように見えることです。簡単なコメットアプリを作成するときに、以前にそのようなものを実装したことがあることを知っています。

それで、誰かがこれを一般化し、それに派手なものを追加しましたか？私は特に、多くの通信チャネルを管理し、しばらく使用されていないチャネルを削除する方法に興味があります。永続性も役立つ場合があります。

これはMQができることですか？