spring-rabbit

1熱

1答えて

rabbitmqのプロパティを変更できますか？spring configとstream rabbit

私のPOCでは、私はSpring Cloud ConfigとSpring Stream Rabbitを使用しています。私は動的にリスナー（同時性）の数を変更したい。それは可能ですか？私は次のようにしたい： 1）キューにたくさんのメッセージがある場合、私は同時性レベルを増やしたい。 2）私のダウンストリームシステムが利用できないシナリオでは、キューからのメッセージの処理を停止したい（短い同時実行レベ

0熱

1答えて

発信メッセージにAMQPメッセージプロパティを設定することはできますか？

私はRabbitMQバインダーでSpring Cloud Streamを使用しています。私はSpring Cloud Streamを使用しない外部サービスを呼び出す必要があります。このサービスでは、typeとcorrelation_idのメッセージプロパティが使用されています。発信メッセージにヘッダーを設定しようとしましたが、技術的にはヘッダーであるにもかかわらず、特別な方法で処理されます。した

3熱

1答えて

実行時に未知のAvroメッセージを特定のJavaクラスに変換することは可能ですか？

Javaアプリケーションでイベントを公開するためのシリアル化フォーマットとしてAvroを検討しています。私がしたいのは、いくつかのAvroバイトをAvro Mavenプラグインを使って生成した特定のJavaクラスのインスタンスに変換することです。逆も同様です。私のコードを使用している開発者が特定のイベントを購読し、その特定のイベントを表す特定の生成クラスのインスタンスを受け取ることができるよう

-2熱

3答えて

Kafka vs Rabbitの長所と短所MQ

KafkaとRabbitMQはよく知られているメッセージブローカーです。私はSpring Bootを使ってマイクロサービスを構築したいと思っています。Spring Cloudは、デフラクトの選択肢としてそれらのためのソリューションを提供しているようです。私はRabbitMQの支配的な部分を知っています。カフカはApacheに属しているので、それはいいはずです。だから、RabbitMQとKafkaの

0熱

1答えて

マルチスレッド環境では、受信するrabbitListenerコンポーネント内にスレッドに依存するデータをどこに格納する必要がありますか？

私は、マルチスレッド環境（私は複数のコンシューマーを持っている>複数のウサギリスナーコンテナ）でspring amqpのアノテーションベースのアプローチを使用しています。 @RabbitListener(queues = "tasks") public void receiveMessage(@Payload Task task) { // usage of httpClient he

1熱

1答えて

春ウサギと春の取引は

私のような春のウサギの消費者を持っています。私はそれをチェックし、私は3つのテーブルにデータを保存し、例外をスローしてから4番目のテーブルに保存します。また、3つのpreviosテーブルのデータはロールバックされません。どのように春にそれを正しく行うには？ onMessageメソッド内のすべてのコードをトランザクション内に置いておきたい。おかげがUPDATE 私のウサギのconf：あなたのトラン

0熱

2答えて

RabbitMQで@StreamListenerを（統合して）テストするにはどうすればよいですか？

テストでアプリケーションを起動し、メッセージを作成し、出力チャンネルにドロップし、メッセージが選択されて処理されるのを待つリスナー春起動アプリケーションの統合テストを作成しようとしています。は、ここで私はテストのために持っているものだ： package com.example; import com.netflix.discovery.converters.Auto; import org

0熱

1答えて

は、私は、「春のうさぎ」の代わりに「春クラウドストリーム」

私はメッセージドリブンフレームワークを採用しようとするプロジェクトに取り組んでいますを使用する必要があります。（異なる独立したコンポーネントは、メッセージブローカーによってルーティングされたメッセージと通信する）最後にブローカーとしてRabbitMQが選ばれました。フレームワークのために、最初に我々は春クラウドストリームを使用しようと、私たちのようなウサギの特性、活用しようとすると：私たちは

2熱

1答えて

Spring AMQPを使用してリスナーに送信する遅延メッセージ

私は、一定期間の後にMessageListenerにメッセージを送信する必要があります。したがって、Spring AMQPを使用して達成する方法はありますか。例：プロデューサーがメッセージを生成し、メッセージがRabbitMQに送られます。Qメッセージが受信されます。リスナーは、すぐにそのQを聞いて、何らかの設定パラメータの後に消費者側で受け取るメッセージを遅らせたいとします。