activemq-artemis

0熱

1答えて

私はActiveMQのアルテミスに新しいです私はDOC読み、コネクタは、それがサーバーに接続する方法を定義するためにクライアントによって使用されて発見しました。私が意味を作っている（私はそれを聞いています、ねえあなたは、ポート61617上で私と一緒に接続することができ、アクセプターを言っているので、ここでコード <connectors> <connector name="net

1熱

1答えて

Apache Artemis：スタティック・クラスタの永続サブスクリプションを作成するにはどうすれば

ここではclustered-durable-subscriptionという例です。ここではclustered-static-discoveryです.1つのサーバー（クラスタ構成を使用して別のサーバーに自動接続）で接続するクラスタ・スタティック・ディスカバリ。ドキュメントごとのようは通常、耐久性のあるサブスクリプションは、単一ノード上に存在し、ActiveMQのアルテミスで、しかし、任意の一時

0熱

1答えて

Apache artemisは多くの接続をSTRICTの設定で多くのサーバーノードを作成する必要があります

私はチェックがclustered-static-discovery、またudpベースのクラスタリングクラスタに2つのノードがある場合は2つの接続が必要ですメッセージをラウンドロビンで消費するためには4つの接続が必要です。 1つの接続またはリスナーしか作成していない場合、2つのサーバーに2つの接続があり、10のメッセージが生成され、5つのメッセージが欠落するとします。多くの接続を作成する代わりに

0熱

1答えて

Spring JMSでFQQNにアクセスするには？次のように

マイアルテミスブローカーが設定されています。 <address name="PublishSubscribeWithPreDefinedQueues"> <multicast> <queue name="Queue1"/> <queue name="Queue2"/> </multicast> </address> にはどうすればQUEUE1に接続する

0熱

1答えて

Artemis：エラー時にメッセージを消費するのを止めるには？

ActiveMQ ArtemisまたはSpring JMSクライアントをエラー時に他のメッセージを消費しないように設定する方法はありますか？次のように私は私のブローカーを構成した： <addresses> <address name="SimplePointToPoint"> <anycast> <queue name="SimplePointToPoint"

0熱

1答えて

Spring-boot appがApache Artemisクラスタに接続する

Spring Factoryは、Artemisがクラスパス上で利用可能になると、Connection Factoryを自動構成できます。しかし、SpringネイティブのArtemisクラスタ（複数のノード）にSpringブートアプリケーションを設定する方法

0熱

1答えて

ActiveMQとMDBs - 古いメッセージを消費することを好む（FIFOを優先する）

同じMDBの〜50個のインスタンス（セッション）によって消費されるActiveMQのキューがあります。問題は、キューが多くのメッセージを受信し、さまざまな分のメッセージを大量に受信することがあることです。消費者は新しいメッセージを引き出しています。古いメッセージは引き出されず、キューはほとんど空になります。キューがいっぱいになっていると（消費者よりもメッセージが多い）、古いメッセージはまったく消

0熱

1答えて

Java EEアプリケーションからJava SEアプリケーションにJMSメッセージを送信する

私の問題は、誤った設定のために概念的なものか技術的なものかはわかりません。目的は、アプリケーションコンテナ（ここではWildFly）でホストされているJava EEアプリケーションと、スタンダードJMSプロトコルとトピックを使用してスタンドアロンで実行されているJava SEアプリケーションの間で双方向のメッセージを送信することです。私は同じブローカーと同じ話題を使用している限り、これは可能です

1熱

2答えて

ActiveMqでファイル文字列を送受信する5.15.2

ActiveMQで巨大なファイルを送信する必要があります。そのために、for Large messageのドキュメントに従っていますが、にファイルを投げています。私の質問があるは、のpom.xml BytesMessage message = session.createBytesMessage(); FileInputStream fileInputStream = new

0熱

1答えて

ActiveMQのベストプロトコルは、不安定な接続を介して

ユースケースを巨大なファイルを送信します。現在のところ、Activemq Artemisサーバを使用して、再試行間隔を-1にしてtcpプロトコルによる入力ストリームの助けを借りて、巨大なファイルをByteMessageとして送信します。ここでの主な問題は、消費者のエンドポイントの接続がほとんど不安定であることです。つまり、移動性のためにネットワークから切断します。ファイルをキューに入れている間