問題タブ [smallrye-reactive-messaging]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Quarkus メッセージ コンシューマの同時実行性 (マルチスレッド)
JMS の世界では、メッセージ駆動型 Bean (MDB)のmaxSessionプロパティを調整することで、同時実行の程度を簡単に定義できます。現在、Quarkus には明らかに MDB がありませんが、同じレベルの同時実行チューニングをどのように達成するのでしょうか?
ガイド ( Quarkus - Using JMS ) を見ましたが、この例で消費者が行うことは、無限ループを使用してメッセージを取得することだけです。すごく悪い例だと思います。構文は理解できますが、メッセージを消費する方法は、忙しく待っているように見えます。
そのため、要点を見逃しているのではないかと考えました。より多くのメッセージをより効率的に処理するには、リアクティブ メッセージングを使用する必要があります。ガイドQuarkus - Using AMPQ with Reactive Messaging を見ましたが、コンシューマーの同時実行性については何も述べていません。この最後の例では、Price Generator Bean はアプリケーション スコープの Bean であり、リアクティブ メッセージング アノテーションを使用して Artemis ブローカーからのメッセージを消費します。
着信チャネル (または JMS キュー) を他のチャネルよりも速く消費したい場合、Quarkus でそれを実現するにはどうすればよいですか? 例を教えてください。