spring-amqp

    0

    1答えて

    トピックを使用してキューにメッセージを送信し、同じメッセージを受信して​​処理する2人のコンシューマを持つことはできますか?現在、私は2つの消費者を作成しているが、キューに入っているトピックを見ているキューを見ているが、最初のコンシューマはメッセージを消費してキューを削除し、2番目のコンシューマはメッセージを受信しない。

    2

    1答えて

    ここでいくつかの関連する質問を見ましたが、うまくいきませんでした。ウサギは別のアプリケーションからのメッセージをシリアル化しません。 Caused by: org.springframework.amqp.AmqpException: No method found for class [B メッセージを受け取るための設定クラス以下。この他の構成を使用して @Configuration pu

    0

    1答えて

    まず、MQTTの使用方法を説明します。 私のバックエンドはいくつかのマイクロサービスで作られてスプリングブートで作られています。私のAPIの消費者は、我々がonesignal使用の携帯電話の更新のためのアプリケーションウェブとモバイル、ですが、「リアルタイムでマップ内の特定などの機能と位置で私たちを満たすことができません "を調査したところ、Rabbitを使用した実装が既にあるため、今日最も多く使

    0

    1答えて

    C# MicroServicesとEasyNetQ、JavaとSpring Amqpの間でメッセージを送信する必要があります。 問題はプロパティメッセージで、SpringブートからのタイプAmqpはプロパティ__type__ヘッダーコンテナにあり、EasynetQではtypeという外部プロパティから予想されます。 誰も私もcomunicateにするためにカスタマイズする必要があることを教えてもらえ

    0

    1答えて

    いくつかの異なるサーバーの単一のインスタンスから多数のクライアントにメッセージを送信する必要のある一連のTomcat/Springアプリケーションがあります。各サーバーインスタンスには、独自の交換セットがあります。エクスチェンジはサーバによって宣言され、各クライアントによって生成され、それらのエクスチェンジにバインドされた匿名キューが宣言されます。私は匿名キューを使用しています。なぜなら、あらかじ

    0

    1答えて

    私はクライアントとRabbitMQサーバー間でPush API通信がどのように機能するかを深く理解しようとしています。 クライアントは、ブローカ(RabbitMQ)へのTCP接続を開いて、クライアントの決定を閉じるまでこの接続を有効にします。しかし、この接続中にクライアントはすぐにメッセージを受け取ることができます。 私の質問は、クライアントがブローカを監視してメッセージを尋ねるか、ブローカがクラ

    0

    1答えて

    おそらくRabbitMQによってスローされる次の例外を防ぐために何が必要ですか? org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener threw exception at org.springframework.amqp.rabbit.listener.

    0

    1答えて

    私は春にアップグレードした後、春ウサギとSpring AMQPのうち、エラーを取得しています5。どちらも、今1.5.6.RELEASEに設定されている 誰もが春と互換性を持つようになっているのリリースを知っていますが5? もっと一般的に、どこかにどこかに保存されているSpringプロジェクトの互換性のあるバージョンのマスターリストがあれば誰でも知っていますか?

    0

    2答えて

    Spring Bootで書かれた以下のプログラムが正常に動作しています。しかし、問題は、RabbitTemplateとAmqpTemplateのどちらを使用すべきかわかりません。オンラインの例/チュートリアルの一部はRabbitTemplateを使用し、その他のものはAmqpTemplateを使用します。 ベストプラクティスとどちらを使用するかをご案内してください。 @SpringBootAppl

    0

    1答えて

    AMQPを介して署名されたJSONオブジェクトでメッセージを送信するプロジェクトがあります。私はAMQPメッセージの内容を取得すると String msg = ...deo // JSON object (String) Object response = getRabbitOperations().convertSendAndReceive(_myExchange, _myRoutingKey