問題タブ [hornetq]

hornetq にメッセージ コンシューマーの遅延を設定するオプションはありますか。もしそうなら、親切に例を手伝ってください。私たちの要件: 一定の 2 分の遅延でメッセージを読み取るには、MDB が必要です。

MDB が複数のキューをリッスンするようにする hornetq の any オプションです。その場合は、サンプルを提供してください。

HornetQ サーバーをスタンドアロンで実行しようとしています。しかし、やり方がわからないので、hornetq-2.0.0.GA をダウンロードし、build.sh を使用してサーバーを起動しましたが、Java コードで HornetQ サーバーを起動しようとしていて、書き込み用のクライアント コードを 1 つ書きたいと考えています。メッセージをキューに入れ、さらにキューから読み取ります。

次の活動で私を助けてください：

1. Java コードで HornetQ サーバー Standalone を起動する方法を知りたいですか?
2. キューにメッセージを読み書きするクライアント コードを記述したい。

JBoss または Tomcat サーバーを使用していないことを覚えておいてください。

私は非常に感謝します、必要なことをしてください。

ありがとう

リモートでホストされている JNDI および HornetQ サーバーで HornetQ jms/queue の例を実行しようとしています。

HornetQ サーバーは 10.0.10.102 で実行されています。10.0.2.62 で実行されているクライアント。サーバー マシンとクライアント マシンの両方が Linux ボックスです。

クライアント側で client-jndi.properties ファイルを次のように構成しました。 java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory java.naming.provider.url=jnp://10.0.10.102:1099 java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces

hornetq-beans.xml 構成ファイルで JNDI 設定を次のように構成しました。

サーバー側の Linux マシン (10.0.10.102) で「rmiregistry」を実行したかどうかに応じて、「接続が拒否されました」というエラーが発生するか、クライアントが JNDI サービスの検索を停止します。

「rmiregistry」を実行しないと、クライアント側で次のエラーが発生します。

サーバー ホストで「rmiregistry」を実行すると、JNDI ルックアップがハングします。

ここにぶら下がっています...

JNDI ルックアップ プロセス用に JNDI または Java 環境を構成するために他に何をする必要があるか考えていますか? ありがとうございました。

クラスタリング (複数のアクティブな HornetQ サーバーが接続されている) を使用せずに、次のコードを使用して、キューのコンシューマーの数を把握しました。

ただし、互いに接続されている複数のアクティブな HornetQ サーバーでクラスター化されたセットアップを使用すると、各サーバーは、それ自体にのみ接続され、他のサーバーには接続されていないコンシューマーのみを返します。

他のサーバーにも接続されているコンシューマーの数を取得するにはどうすればよいですか?

メッセージを作成して HornetQ に投稿できるストアド プロシージャを SQL Server 2008 に作成する必要があります。いくつかの検索を行ったところ、2 つのオプションがあるようです。

• メッセージの作成と送信に使用できるアセンブリをSQLサーバーに登録していますが、この目的に使用できるライブラリはありますか、それとも独自に開発する必要がありますか?

• HornetQ REST API を使用していますが、これが可能かどうかはわかりません。可能であれば、どうすればよいですか?

そして私の最後の質問：SQLサーバー内で（毎分実行されるスケジュールされたジョブであっても）メッセージを消費することは可能ですか？

ありがとう

JBoss 7.0.2 インスタンスで作業しています。私たちのアプリは戦争であり、メッセージはキューにドロップされます. これはうまくいきます。しかし、リスナーを介してそれを読み取ると、システムは例外をスローします。WEB-INF/classes に存在するクラスを探しています。

モジュールクラスローダー (私が正しければ HornetMQ) がこのアプリケーションクラスを認識できず、スローアップしていることを理解しています。アプリケーション クラスをサーバー ライブラリの一部にしたくありません。戦争の中で生きるその階級は最高の場所です。

例外は次のとおりです。

これを機能させるにはどうすればよいですか？

よろしく。

アショク

クラスタ化された環境に JBoss-Server の複数のインスタンスがあります。バックグラウンド タスクには、登録されているすべてのジョブを管理するグローバル キューが利用可能です。このキューでは、各ノードに単純なリスナー (MDB) があり、着信メッセージを管理します。このリスナーは、シングルトン Bean の手動ルックアップ (インジェクションなし) を実行し、事前定義されたメソッドを開始します。これまでのところすべて正常に動作していますが、シングルトン Bean のメソッドは、状況によっては利用できない他の (シングルトン サービスではない) を使用しています。たとえば、ノードが再起動され、キューにメッセージが残っている (まだ処理されていない) 場合、メッセージはリスナーによって取得され、それ以降のすべての Bean は null になるため、ジョブは NPE を生成します。メッセージが取得された後、JMS-Listener で遅延時間を定義することは可能ですか?

MDB プロパティの "DeliveryActive" を false に設定し、完全なデプロイ後に Bean を開始することもできます。これをプログラムで（jmx-consoleではなく）簡単に実行できる方法はありますか？これに関するマニュアルを見つけた場合は、手動の jndi ルックアップにリダイレクトされます。アノテーションごとに Bean を注入して startDelivery() を呼び出すことが可能でなければならないと思いますか? アプリケーションでこれを行うのに適した場所はありますか?

別のヒントとして、application.xml の initialise in order プロパティに移動します。これは、問題が JBoss の展開順序に関連している可能性があるためです (一部の EJB はリスナーよりも後で使用可能になります)。ただし、JBoss 6.0にバグがあり、アップグレードすると6.1. オプションではありません。多分これのためのウォークスルーがありますか？

問題が十分に説明されていることを願っています。それ以外の場合は、さらに情報を求めてください。

前もってありがとう、ダニー

追加情報:

• JBoss 6.0.0 最終版
• HornetQ 2.2.5 Final (JBoss のデフォルト バージョンにバグがあるため、更新済み)

リスナー：

サンプル ワーカー:

この場合、sampleEjb - メンバーは時々 null になります

2 つのマシン (x.my-domain.com と y.my-domain.com など) で静的クラスタリングを使用して、hornetq サーバーの 2 つのインスタンスが実行される hornetq クラスターをセットアップしようとしています。~/hornetq-2.2.5.Final/examples/jms/clustered-static-discovery/server{0,1}/hornetq-configuration.xml にあるデフォルト設定を各サーバーに 1 つずつ使用します。 . server0/server1 の下の構成ファイルに既に別のコネクタ ポート/コネクタ名/コネクタ参照があるため、これが機能することを願っています。

また、構成ディレクトリの下には、いくつかのデフォルトの dir/ ファイル (jboss-as-4、jboss-as-5、ra.xml、スタンドアロン) があります。上記のように、それらをすべて削除して hornetq-configuration.xml のみを配置する必要がありますか?