問題タブ [message-queue]

Oracle データベースのストアド プロシージャを使用して、メッセージを WebSphere MQ キュー (注: ポイント ツー ポイント キュー -- トピックではありません) にキューイングしています。1 回の呼び出しで各メッセージを複数のキューに発行する方法はありますか? 私が望むのは、メッセージを単一のキューに送信する場合と比較して、データベースに追加の遅延が発生しないソリューションを見つけることです。

WebSphere MQ 設定の変更を伴う解決策は大歓迎です! 私が念頭に置いていたのは、元のメッセージと同じメッセージをすべて取得する「クローン」キューを何らかの方法で作成することでしたが、ドキュメントでこのようなものを見つけることができませんでした.

ありがとう、ジェフ

2 つのメッセージ駆動型 Bean があります。これらの Bean の 2 つのアクティベーション スペック。1 つのメッセージ バスがあり、両方のアクティベーション スペックがこの 1 つのバスに構成されています。2 つの異なるキューと、その 1 つのメッセージ バス用に構成された 1 つのキュー接続ファクトリがあります。

ここで、キューを決定した後、実行時にキューの 1 つにメッセージを送信するコードを記述します。ただし、両方の MDB が同じメッセージを受け取ります。この構成は一般的にどのように行われますか? 常に 1 つのキュー -> 1 つのキュー接続ファクトリー -> 1 つのメッセージ バス -> 1 つの MDB を構成する必要がありますか? それはすべて一対一の関係ですか？

言い忘れていましたが、私は Websphere Application Server v6.1 を使用しています。

私はJMSとApacheActiveMQについて少し読んでいました。そして、ここの人々は、JMSまたは同様のメッセージキューテクノロジーを実際にどのように使用しているのか疑問に思っていましたか？

クライアント アプリケーションから RabbitMQ キュー内のメッセージ数を確認する方法があるかどうかは誰にもわかりませんか?

.NET クライアント ライブラリを使用しています。

私は、Websphere MQ キューにメッセージを投稿し、応答のために別のキューをポーリングする .NET Windows Forms アプリケーションを作成しています。応答が返された場合、アプリケーションはリアルタイムで応答を部分的に処理します。ただし、応答キューからも読み取る毎日のバッチ ジョブが残りの処理を実行できるように、応答はキューにとどまる必要があります。

メッセージを読むところまで来ました。私が理解できなかったのは、それを削除せずに読む方法です。

これが私がこれまでに得たものです。私は MQ の初心者なので、提案をいただければ幸いです。そして、C# で自由に応答してください。

注:私のコードが実際にメッセージを削除することを確認していません。しかし、それが MQ が機能することを私が理解している方法であり、それが起こっていることのようです。それがデフォルトの動作でない場合は、修正してください。

私は、理想的には目立たず、非常に邪魔にならない時間管理ツールを wxPython で作成しようとしています。これまでのアプリは通常どおり使用でき、使用中はシステム トレイに最小化されます。

ただし、「アイコン化」されているときのように、フレームがフォーカスされていない場合、フレーム/アプリがフォーカスされているときに通常は機能するマウスとキーボードのトラッピングが機能しなくなることに気付きました。

メッセージ キュー フックを作成し、すべてのマウスおよびキーボード イベントを OS レベルでトラップする C++ プログラムを作成できることは承知していますが、そこまでは考えたくありません。結局のところ、手を汚さないようにするために、そもそも wxPython で UI を書いているのです :)

サーバー内のスレッド間通信にメッセージ キューを使用しています。木曜日の夜、サーバーは期待どおりに機能していました。月曜日にプロジェクトを再開したところ、使用中の 6 つのキューのうち 2 つを作成できませんでした。これは、それらが既に開いているためです (O _EXCL が設定されています)。これはあってはならないことですが、それでも、エラー チェックを伴う mq unlink 呼び出しを追加し、 mq openから_O _EXCL フラグを削除しました。_

_コンパイルして実行すると、mq unlink と mq openの両方で errno が EEXIST に設定されました_。mq _unlink はどのような状況でも errno を EEXIST に設定できず、mq _open は O _EXCL フラグが設定されている場合にのみ EEXIST を設定できます。

なぜこれが起こっているのですか？

どちらを使うべきか少し混乱しています。どちらでもうまくいくと思いますが、どちらがもう一方よりも優れているのでしょうか、それとも適切でしょうか？

http://github.com/ask/carrot/tree/master

http://github.com/ask/celery/tree/master

私は Django プロジェクトのメッセージ キューに Carrot を使用しており、チュートリアルに従っていますが、正常に動作します。しかし、この例はコンソールで実行されます。これを Django でどのように適用するのか疑問に思っています。models.py のモデルの 1 つから呼び出しているパブリッシャー クラスなので、問題ありません。しかし、消費者クラスをどこに置くべきかわかりません。

.wait() でそこに座っているだけなので、いつでも実行してメッセージをリッスンできるようにインスタンス化する必要があるポイントや場所がわかりません!

ありがとう！

私は解決策を見つけようとしていますが、実際に機能するものは何もありません。私は (とりわけ) メールを送信するシステムを構築しており、メッセージのキューイングを機能させる方法を見つけようとしています。これまでに送信されたメッセージの (ある程度) 正確な数をユーザーに提供したいと思います。私は、ユーザー向けのページを用意し、次に送信プロセスを開始して継続的に出力する別のページ (更新のようなものではなく、リアルタイム出力のようなもの) を作成し、それを解析して情報をよりユーザーフレンドリーにすることを考えていました。 . これを行う方法についての提案をお待ちしております。事前にアイデアをお寄せいただきありがとうございます。