activemq

4熱

1答えて

ネットワークで負荷分散のために3つのブローカーを設定しようとしています。クライアントとプロデューサーはこれらのブローカーのいずれかに接続できます。質問：これらのブローカーをネットワークに使用するための推奨トポロジーとは何ですか？具体的には、これらのブローカーのそれぞれで使用するnetworkConnector構成は何ですか？二重化設定を有効にする必要がありますか？（私は推測デュプレックス設定

3熱

1答えて

ActiveMQ createSession timeout

ActiveMQ接続からセッションオブジェクトを作成するときにタイムアウトを設定する方法はありますか？次のように私はルックスを使用しているコード： ConnectionFactory factory = Settings.getJmsConnectionFactory(ip); connection = factory.createConnection(); // insert timeou

0熱

2答えて

JMSとThreadPoolの問題？

1つのスレッドがメッセージを処理したときにjmsがメッセージを受け取るようにしたい（threadPoolが呼び出し可能にする）。メッセージはマスタースレッドによって受信されます。私は春3.0.5を使用します：マスタースレッドのウェイ1に ApplicationContext context = new ClassPathXmlApplicationContext( "applicat

2熱

1答えて

ActiveMQコンソールが利用できません

WindowsマシンにActiveMQ 5.5.0をインストールしました.Webコンソール（http：// localhost：8161/admin）をそのまま使用できました。それから私は、リモートのLinuxボックス（IP：つまりaaa.bbb.ccc.dddという）にActiveMQの（同じバージョン）をインストールし、私は http://AAA.BBB.CCC.DDD:8161/admin

2熱

3答えて

activemq、jmsトピックとセレクタを持つサブスクライバ

トピックとセレクタに関する助けが必要です。複数の恒久サブスクライバ（セレクタを持つ）を持つトピックのシナリオがあります。セレクタが一致しないため、トピックに入るメッセージのすべてがコンシューマによって読み取られるわけではありません。これは正しい動作です。しかし、この時点で他のメッセージはコンシューマに配信されていないため、不一致のメッセージが特定の数量のしきい値に達したときに問題が発生しま

2熱

1答えて

ユーザ名/パスワードでactiveMQへの接続を認証します。

私はokを実行しているアプリケーションをactivemqに送信しています。私はspring.netとNmstemplateを使ってブローカーに接続しています。一般的に XML設定ファイルは次のとおりです。 <object id="ActiveMqConnectionFactory" type="Apache.NMS.ActiveMQ.ConnectionFactory, Apache.

1熱

2答えて

ActiveMq、使用されていないメッセージは常にブローカのメモリにありますか？

私はActiveMQを使用しています。消費者を待っている間、永続化されたメッセージが実際にディスクにスワップされる方法と時期について質問がありますか？私は仮想トピックを使用しており、メッセージを受信するキューコンシューマを作成しています。すべてのメッセージはです。です（消費されていないすべてのメッセージのレコードが持続性ストレージに存在することが確認されています）。私は定期的に複数のコンシュー

3熱

2答えて

アクティブMQ JMX SSL

Active MQが作成するJMXコネクタでSSLを使用しようとしていますが、成功しません。私はSSLをJVMプラットフォームのJMXコネクタで動作させることができますが、キーストアとトラストストアのパスワードをプレーンテキストで保存する必要があります。次のように指示hereを使用しては、私がactivemq.xmlにmanagementContextを設定します。 <managementCon

4熱

2答えて

アクティブMQ - ブローカーのネットワーク

私は以下のようなトポロジーを持つブローカーのネットワークを構成しました。プロデューサーブローカ（B2）に接続されたブローカ（B1）とプロデューサー（P2）に接続されている（P1）ブローカ（B1）とブローカー（B2）は、ブローカーのネットワークとして接続され、をバランスLAODれますブローカ（B1）と消費者（C2）に接続コンシューマー（C1）クライアントは、次のようにフェールオーバーを使用す

0熱

1答えて

javax.jms.InvalidDestinationException：私はクライアントに私にメッセージを送信するためのActiveMQブローカーに接続するプロデューサーを持っている別のConnection

から一時的な送り先を使用することはできません。それはクライアントからいくつかの応答を期待するので、最初の一時キューを作成し、ヘッダREPLYTO JMSにそれを関連付けます。次に、メッセージをブローカに送信し、クライアントからの一時キューに対する応答を待ちます。クライアントからの応答を一時キュー経由で受信し、必要なアクションを実行してから終了します。これはほとんどの場合うまく動作しますが、