activemq

0熱

1答えて

複数の恒久サブスクライバでアクティブなトピックが保持できるメッセージ数はいくつですか？

トピックに登録している複数の恒久サブスクライバがありますか？トピックが保持できるメッセージの数はいくつですか？それが保持できるメッセージの最大数はいくらですか？私は、永続性アダプタとしてKahaDBを使用しています。私はそれがKahaDBが持っているメモリの量に依存していると仮定しています。そうですか？

1熱

1答えて

JOOQ接続グラブを使用したプール

私はactivemqから読み込み、activemqから取得した値のストアドプロシージャを実行しています。私は通常の速度で大量に実行しようとしていますので、activemqからメッセージを読み込んでストアドプロシージャを実行するためのスレッディングが含まれていました。これを実行すると、JOOQが接続プールを使用していないことがわかり、すべてのSQL操作が順番に実行されています。 JOOQログイン

1熱

1答えて

CamelContextがPooledConnectionFactoryの初期化中にシャットダウンしています

ActiveMQComponentをcamel cdiでorg.apache.activemq.pool.PooledConnectionFactorを使用して初期化しようとしています。 ActiveMQConnectionFactoryでは、正常に動作しています。ログをいくつか追加しましたが、PooledConnectionFactory、CamelContextがシャットダウンしているときに

0熱

2答えて

メッセージが再配信ポリシーの後にActivemqのDead LetterQueue（DLQ）に送られないようにする方法

private BrokerService createBroker() throws IOException, Exception { BrokerService broker = new BrokerService();KahaDBStore kaha=new KahaDBStore(); File file =new File(path); Transpo

0熱

1答えて

ActiveMQに同じclientIdを持つ複数のサービスインスタンスを持つことは可能でしょうか？

2つのコンシューマがそれぞれ独自の接続を使用してテストを作成しました。そのうちの1人だけがメッセージを受け取るようにする必要があります。これらのコンシューマは、同じclientIdと名前を使用します。私は次の例外を取得秒消費者のためのclientIdを設定するたびに： Apache.NMS.InvalidClientIDException：ブローカー：ローカルホスト - クライアント：すでにT

-1熱

1答えて

Java ActiveMQ：クライアントからサーバーにメッセージを送信する方法

サーバー/プロデューサからクライアントにメッセージを送信する方法に関する多くのコードと例を見てきましたが、クライアントからサーバーにメッセージを送信します。それは同じ形式に従っていますか？たとえば、私のサーバーにはA、B、C、D、Eという5つのトピックがあります。クライアントはトピックCだけを聞いています。したがって、サーバーはキューを作成し、購読者/クライアントにメッセージを送信します。私

1熱

1答えて

Activemq PooledConnectionFactoryにおける有効期限のタイムアウトの意味は何ですか？

私は、Activemq PooledConnectionFactoryのexpiryTimeoutフィールドのアプリケーションを理解していません。 javaドキュメントでは、「接続が負荷またはアイドル時間に関係なく期限切れになる」と述べています。これは、プールからの再接続を強制するフェイルオーバーや、負荷分散またはマスター・ポスト・リカバリの使用を再確立するのに便利です。私に例を与えてください、実

0熱

1答えて

Camel JMSComponentがJUnitに登録されていませんエンドポイントの解決に失敗しました

JamitのテストケースとiamでJMSQueueにメッセージを送信しようとしましたが、scheme：hornetqでコンポーネントが見つかりませんでした。 Bean宣言にコンポーネントを登録しました。でも、まだそれはエラーを投げています。 JUnitテストクラス：テストリソースにHornetQは有する import java.io.File; import org.apache.camel.

0熱

1答えて

メッセージの並べ替え - Artemis

私の場合、 'queue-1'からメッセージを読み込んで別のキュー 'queue-2'に書き戻す同じアプリケーションの2つのインスタンスを実行する必要があります。私は2つのキュー内のメッセージを、プロデューサによってすべてのメッセージに最初に追加される特定のプロパティ（シーケンス番号）によって順序付けする必要があります。ドキュメントごとに、キュー-1の内部では、メッセージが単一のプロデューサによっ

0熱

1答えて

メッセージ指向のミドルウェア - このコンセプトを実装する製品？

私はメッセージ指向のミドルウェア（MOM）を勉強しようとしており、オンライン資料を参照しています。私は、MOMを使用して2つの異種システム間でメッセージの受け渡しを行うことを理解しています。私はまた、のような様々な製品を知っているようになりました： IBM MQ/IBMのWebSphere MQ/IBM MQSeriesの RabbitMQののApache ActiveMQのがコンセプトの