jms-topic

0熱

2答えて

PythonにQpidを使用すると、コンテナを使用してコネクタURLを使用してActiveMqに接続しています。 username：password @ hostname：5672/topicName。ウェブコンソールでAMQPの接続がアップしています。しかし、既存のトピックに登録するのではなく、その名前の新しいキューを作成します。誰かがトピックを購読するために与えなければならない形式で私を助

0熱

1答えて

Temp Queue autoを防止するActiveMQのトピック作成

ActiveMQで一時キューを作成するRestサービスを使用して、受信応答を受信しました。すべての要求は、一時キューを作成します。私は、トピックリストに行くとき、私は次の表示：各一時キューのを、自動的にトピックを作成しています。その主な問題は、トピックには1,000のトピックに制限があることです。これを超えると、ActiveMQのアプリケーションからメッセージが受け付けられなくなります。

0熱

1答えて

のActiveMQ GETデキューまたは消費されるメッセージ

消費メッセージを取得する方法はありますが、私は、ブローカーが消費としてそれをマークし、メッセージは、それがなくなって消費された後のActiveMQ

0熱

1答えて

QPID JMSを使用してazure servicebusからのトピックサブスクリプションからのメッセージを受信

私はこのサブスクリプションからのメッセージを読むためにtutorialに従っています。このprogramIを実行するには public class Receive implements MessageListener{ private static boolean runReceiver = true; private Connection connection;

0熱

1答えて

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

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

0熱

1答えて

ActiveMqのトピック内のメッセージが配信されるユーザの最大数を制限する

ActiveMqインスタンスがあり、トピックをリスンするクライアントが100人いるとします。新しいメッセージがトピックに公開されると、それを受信するサブスクライバの数を制限できますか（例10のみ）？他のメッセージングコンポーネントがこれを行うことができますか、回避策/強化されたベストプラクティスがある場合は、

0熱

1答えて

JMS接続がJMSSecurityExceptionをスローしない不正なルートにメッセージを送信するとき

Javaサービスからメッセージを送信するためにSpringでApache Camelを使用しています。交換時にエラーが発生した場合、特定のイベントを処理/トリガーする必要があります。私は私の目的を達成するために以下のコードを使用しています。私は間違ったルート名broadcast.SIMULATOR.ROUTE1、エンドポイントの値を設定しテストするために try { prod

0熱

1答えて

JMS TopicBrowser Import

耐久性のあるサブスクライバのメッセージを表示するのにTopicBrowser（ドキュメントhereおよびhere）を使用しようとしていますが、コードでインポートする正しい方法が見つかりません。私はJavaに慣れていないので、ドキュメントに何か不足している可能性があります。

1熱

1答えて

スプリングjmsは永続的トピックリスナー間でメッセージをどのように配布しますか？

生JMSコード： TopicSubscriber durSubscriber1 = receiverSession.createDurableSubscriber(topic,"subscription_1"); durSubscriber1.setMessageListener(new MessageListener() { @Override public void on