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答えて

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

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

0熱

1答えて

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

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