Spring AMQPでスレッドを実装中にメッセージが消費される

Question

Spring AMQPを使用してRabbitMQからメッセージを消費するアプリケーションがあります。 要求を処理するには、コンシューマにスレッドを実装する必要があります。私のスレッドプールが利用可能な場合、私はメッセージを処理するスレッドを使用してメッセージを消費しています。

私は、すべてのスレッドがビジー状態のときに何が起こるのかという質問があります。私は それを処理するスレッドがありません。メッセージは RabbitMQから消費されますか？私のスレッドプールが利用可能になるまで待ちます。どうすれば これをspring amqpを使って処理するのですか？

Spring AMQP側から実装されるスレッドロジックはありますか？

お勧めします。

Answer 1

リスナーに独自のスレッディングを追加しないでください。メッセージが早く消えてしまい、失われる可能性があります。代わりに、コンテナのconcurrentConsumersプロパティを使用して、使用するスレッドの数を判断します。

このような質問をする前に、configuration optionsの全文を読むことをおすすめします。