問題タブ [sonicmq]

メッセージを JMS キューに送信する Java コードを作成しています。「QueueSender.send()」を使用してこれを行っています。

JMS キュー自体は sonicMQ ですが、それは的外れです。

私の問題は、JMS キューがいっぱいになり、キューにメッセージを送信しようとするスレッドが不足することがあることです。

メッセージを送信する前にキューがいっぱいかどうかを知る方法はありますか? この場合、ログに例外を出力したいと思います。

ところで、JMS キューのコード自体は私の手の届かないところにあります。クライアントコードだけしか変更できません。

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

接続先の SonicMQ 環境内のさまざまな項目を一覧表示するテスト ユーティリティを作成しようとしています。ブローカー、コンテナー、およびキューを含む多くの項目をリストすることができましたが、トピックは引き続きわかりません。API ドキュメントを検索し、コードを少しいじってみましたが、役に立ちませんでした。

SonicMQ でトピックを一覧表示する方法はありますか? おそらく、すべての宛先 (キューとトピック) をリストするより一般的な方法はありますか? この情報を得るために私が見逃した JMS の何かがありますか?

これが私が1日頭を悩ませてきたものです。
私は古いバージョンの jboss (jboss4) を使用しており、その中からいくつかのコードを起動して、クライアントとして実行している sonic mq (7.6 だと思います) の実装に接続しています。Java 1.6.0_23 を実行しています。そうは言っても、私には理解できないような非常に奇妙な動作が見られます。

プロセスが開始したら、sonic mq サーバーへの接続を確立するために必要なすべての jndi props をロードし、次のように呼び出します。

しかし、その時点でワイヤシャークにトラフィックが見られず、困惑しています。最終的にこれはタイムアウトになり、例外が発生します

歯の本当のキックは、同じサーバー上で (jboss 内ではなく) スタンドアロンの jar からプロセスを実行し、正常に接続することです。

バージョン 3.1.2 を実行しているグラスフィッシュ インスタンスがあります。JMS 経由でリモート サーバーに接続する必要があります。リモート システムは、SonicMQ を使用していると思います。

問題なくリモートサーバーと通信できるJARの例（リモートサーバー会社から）があります。

GlassFish を正しく構成したと思いますが、リモート サーバーに接続できません。グラスフィッシュのping機能を接続/使用すると、常に同じエラーが発生します。

PortMapper がないため、ポート 12506 が正しいです。AddressListパラメータは代わりmqtcp://remote.server.com:12506にmq://remote.server.com:12506

解決策を半日グーグル検索しましたが、何も見つかりませんでした。誰か提案がありますか？私は何を間違っていますか？

SonicMQ（バージョン7.6）を使用しています。本番環境でトピックを設定し、そのトピックにメッセージを公開するコードを作成しました。これらのメッセージを、別のサイトのSonicブローカーで実行されているキューに複製したいと思います。
ブローカーやサイト間でこのトピックからキューへのレプリケーションを実行するようにSonicMQを構成することは可能ですか？

JMeterのポイントツーポイント機能を使用してSonicESBをテストしようとしています。

私はSonicESBでサービスを開発しました（プロトタイプステップが1つしかない非常に単純なサービス）。JMeterからSonicESBで開発したサービスにメッセージを渡し、応答を返したいと思いました。

Sample.Q1という名前の入力キューがあります。

JMeterとSonicESBをリンクする方法について本当に混乱しています。

jmeterポイントツーポイントを作成する際に、次のリンクをたどりました。http://jmeter.apache.org/usermanual/build-jms-point-to-point-test-plan.html

認証の詳細（ユーザー名とパスワードなど）も提供する方法を教えてください。

非同期 JMS メッセージング システム用の同期 HTTP 要求応答フロント エンドがあります。

各 HTTPRequest の HTTP クエリ サーブレットは、対応する JMS メッセージをクエリ キューに作成します。このクエリはバックエンドによって処理され、このクエリに対していくつかの応答メッセージが作成されます。JMS で応答メッセージの受信を整理し、それらが適切なサーブレット スレッドに到達して HTTPResponse を作成できるようにするための適切な方法は何ですか?

クエリと応答は非トランザクションであり、永続化する必要はありません。それらのほとんどは読み取りクエリです。45 秒以内に応答が読み取られない場合、サーブレットはタイムアウト応答を生成します。ただし、スループットは重要です。ますます多くのクエリを処理する必要があります。このシステムは約 10 年前のもので、あと 2 年ほど稼働し続ける必要があります。

SonicMQ を使用しています。すべての応答に対して 1 つのキューを作成しました。サーブレット コンテナーには、読み取りと書き込みの両方に使用するブローカーへの接続が 1 つあります。ログインしたユーザーごとに 1 つのリスナー スレッドを生成します (約 1500 の同時実行)。このスレッドには、この特定のユーザーの応答メッセージのみを選択するメッセージ セレクターを備えた受信機があります。サーブレット スレッドがクエリ メッセージを送信すると、ユーザーのリスナー スレッドが応答を読み取ったことを通知するまで待機します。

以前は、すべての送信者とすべての受信者が 1 つの QueueSession を共有していました。セッションは公式にはスレッドセーフではありませんが、これは実際に機能しました(!)。スレッド (サーブレット スレッドとリスナー スレッド) ごとに 1 つの QueueSession を作成すると、パフォーマンスがいくらか改善されましたが、それでもまだ安定していません。

メッセージセレクターを備えた単一のキューではなく、ユーザーセッションごとに一時キューを作成しようとしましたが、かなり遅くなりました。

これを整理するためのより良い/適切な方法は何でしょうか?

私は SonicMQ のまったくの初心者なので、SonicMQ キュー サブスクライバーが何であるかを判断する方法があるかどうか疑問に思っていました。これは、コンソール、ログ ファイル (ログ レベルを Verbose に上げる) などを使用することを意味します。SonicMQ サーバーに接続し、 HermesJMSクライアントを使用して問題のキューにアクセスできますが、キューが何であるかを判断できないようです。消費者は。メッセージは到着するとすぐに配信されるため、キューは常に空です。

何か案は？ありがとう

Glassfish サーバーと Delphi の間で通信を行う必要があります。そこからメッセージを受け取る必要があります。私が発見したように、Glassfish は OpenMQ ブローカーを使用しています。

まず、デルファイの jms ライブラリを見つけました。JMSインターフェースだけが見つかりました。そこに SonicMQ JMS の実装が見つかりました。しかし、私が見つけたように、SonicMQ と OpenMQ - JMS の異なるブローカーです。たぶん私は間違っています。

また、OpenMQ 用の Habari Client Libraries を見つけましたが、このライブラリは無料ではありません。

多分誰かがこの問題の無料の解決策を知っていますか? または、私は間違っていて、SonicMQ の実装を使用できますか?

Habari デモ プログラムをダウンロードしましたが、glassfish サーバーに接続できません (接続が正常に閉じられました)。多分私は何か間違ったことをしていますか？メッセージを受け取るだけです。私はそれらを送る必要はありません。

JMS を使用したことがないため、そのような質問があります。