jms-topic

0熱

1答えて

私は、Pub/Sub通信用のTibco EMS Topicsを使用してクライアントサーバアプリケーションを開発中です。我々は> 200kの「科目」に分割分あたりのメッセージの数百万を送信する必要が私たちのユースケースの一つで。各クライアントは、サブスクリプションする必要があるサブジェクトの小さなサブセットに関心があります。質問は、より合理的であるこれらの実装され、次のとおりです。は、単一の

0熱

1答えて

サブスクライバがMqttトピックで非アクティブなときにプロデューサによって送信されたすべてのデータを取得する方法Java（保持されていないメッセージまたは最後のメッセージ）

私はインターネット上で探してきました。私は清掃 "偽"とqos 1と2を設定しようとしましたが、加入者はオンラインになるとすべてのコンテンツを取得していません。助けてください...私のコードは Example.java（プロデューサー） public class Example extends PersonBean { public void hey(){ String clientId =

-2熱

1答えて

購読して同じActiveMQトピックに公開することができます

トピックにメッセージを保存するソフトウェアコンポーネントがあります。これは、コンポーネントがまだ動作しているかどうかを確認するための「キープアライブ」機能です。メッセージをトピックに置くコンポーネントも、同じトピックでリッスンする必要があります。 ActiveMQが応答しません。つまり、公開されたアイテムの購読が機能していません。この機能を変更できるActiveMQの設定はどこにありますか？私

1熱

1答えて

WSO2 CEP

run()がスリープ状態になる。このlink として炭素 - 分析 - 一般的なプロジェクトのMQTTAdapterListenerのソースコードで更新 MQTT接続には時間がかかります。 @Override public void run() { while (!connectionSucceeded) { try { MQTTEventAdapterCon

0熱

1答えて

ActiveMQ.Advisory.Expired.Queueで非永続的なactivemq期限切れのメッセージを繰り返します。

activemqでアプリケーションを構築しています。ここで、私の配信モードはNON_PERSISTENT（iamはPERSISTENT配信モードを扱っていません。私のデザインではないDLQに格納されます。）、producer.setTimeToLive（2000）を使用してメッセージの生存時間を設定しました。メッセージが2秒で期限切れになると機能が伝えます。私は期限切れのメッセージがActive

2熱

1答えて

WSO2 MB 3.1.0でトピックを購読する方法

私はWSO2 Message Brokerをしばらく使っていましたが、キューとの間でメッセージを送受信する方法をよく理解していました。 thisによれば、この特定のsectionがコードレベルから永続サブスクリプションを作成することについて話す管理コンソールから、特定のトピックをどのように購読することができますかについてはどこにも言及されていません。しかし、これのバージョンには、コンソールか

1熱

1答えて

JMS複数のインスタンス

と、クラスタ内の永続サブスクライバ私はところでペーシュ・カショーロを使用するつもりです.... は私が持っていると仮定します。 A JMSトピック構成されたアンMDBとして耐久性トピックサブスクライバ MDBの複数のインスタンスがクラスタ全体に展開され、彼らはすべて同じクライアントID値を使用して耐久性サブスクリプションを作成しています。このシナリオで、クライアントのID値と耐久性サブスクリプ

0熱

1答えて

永続サブスクリプションIDはJMeterのCSVデータセット構成で読み取ることができません

1から10までの整数値を含むcsvファイルから設定する永続サブスクリプションIDを読み取ることによって、メッセージブローカーに追加された10人の恒久サブスクライバを取得する必要がありますしかし、JMeterは値を読み取ることに失敗しましたが、サブ購読IDを$ {id}として設定しようとしました。以下はJMeterで行った設定です。私は、ユーザ定義の変数で同じことをしようとしたとき、それは、変数の