spring-amqp

0熱

2答えて

Spring AMQP - BeanにListenerContainerを渡します

現在、私はリスナーの最大数を動的に変更する必要があるため、Spring AMQP Listener ContainerをBeanに渡そうとしています（ただし、メモリの制限があります。リスナーコンテナは私を箱から出してくれます）。私の考えは、1秒おきに呼び出されるmanageListenerContainer Beanを作成し、それに応じてconcurrentConsumers属性を変更することで

1熱

1答えて

Spring Cloud DataFlow RabbitMQ min-start-interval

私は、アプリケーションを起動するとすぐに50人のウサギの消費者を始め、必要に応じて500人までの消費者をより多くの消費者で開始したいと考えています。デプロイヤーのapplication.yamlにRabbitMQのstartConsumerMinIntervalを設定するにはどうすればよいですか？私はSpring AMQPのドキュメントでstartConsumerMinIntervalのプロパテ

0熱

1答えて

SpringAMQP RabbitMQ Exchangeなしでキューに直接送る方法

私はRabbitテンプレートでSpringAMQPを使用しています。 Exchangeを省略したキューにメッセージを直接送信する方法どうすればいいですか？

0熱

1答えて

MessageListenerが例外をスローすると、RabbitMQリスナーはリッスンメッセージを停止します

私はRabbitMQでメッセージを処理するためにSpring AMQPを使用しています。問題は次のとおりです。 1. RabbitMQ内で準備状態のメッセージが3つあります。 2.最初に1つがMessageListenerによって取得され、処理が開始されます。（例）例外がスローされて終了する 3.この場合、コンテナを再起動するまで、残りの2つのメッセージは処理されません。また、最初のメッセージ

1熱

1答えて

春の統合AMQP - メッセージが時折解凍されず、タイムアウトが必要ですか？

私はRabbitMQの受信チャンネルのアダプタを1日に3000件のメッセージを正常に処理していますが、RabbitMQ管理コンソールでメッセージが1回しか受信されないことがあります。これはそのように残るようです。私は3回再試行し、デッドレタールーティングキーを使用してDLQに移動するための再試行アドバイスチェーンを持っていますが、ほとんどの例外でうまくいきました。最後の数週間でunackedが

1熱

1答えて

rabbitmq dockerでspring-bootからrabbitmqのキューを作成する方法

spring-amqpサンプルプロジェクトを取得して、rabbitmqのドッカーバージョンに対して実行しようとすると、私はちょうど標準のrabbitmqドッカーを実行しています。接続に問題はありませんが、キューを作成する際には常に例外が発生しますが、現時点で可能なすべてのバリアントを試しました。私は、サンプルプロジェクトのような構成でキューを宣言しようとしました。明示的にRabbitAdminを

0熱

1答えて

TestSuite内の模擬AMQPTemplate

私はTestSuiteとしてJUnitsを実行しています。 JUnitクラスの1つは、メッセージをRabbitMQにパブリッシュするコードをテストするためのクラスです。私はMQにメッセージを公開するコードを偽装しています。どうやってやるの？設定XML自体のRabbitTemplate設定を変更することは可能ですか？ビジネスロジックとクラス： public class SomeClassImp

0熱

1答えて

Spring AMQP：AsyncRabbitTemplate複数インスタンス

マルチインスタンス環境でAsyncRabbitTemplateを使用できますか？私の場合、要求を送信するインスタンスは応答を処理するインスタンスではない可能性があります。 AsyncRabbitTemplateはConcurrentHashMapで送信されたメッセージを追跡しているので、コンシューマが参照を持つメッセージを消費するかどうかは疑問です。これが完全に間違ったアプローチである場合は、

1熱

1答えて

Springリスナー・コンテナ（トランザクション・マネージャとリトライ・アドバイス・オーダー）

リトライ・コンテキスト内で、Springリスナー・コンテナがトランザクションをどのように処理するかを理解しようとしていました。私はこのようなものに構成： <rabbit:listener-container connection-factory="connectionFactory" transaction-manager="chainedTransactionManage