問題タブ [smallrye]
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.
multithreading - Quarkus Reactive Messaging は、JMS コネクタと SmallRye 実装を使用して個別のスレッドを開始しません
私のシナリオでは、アプリケーションは CDI-Producer を使用して JMS キューからメッセージを読み取ります。
私は quarkus-smallrye 実装を使用しています。
コネクタは非常に単純に見えます。
構成:
メッセージを処理するさまざまな方法を試しましたが、いずれの場合もワーカー スレッドは 1 つしかありませんでした。
ログには毎回同じ結果が表示されます。
私はこのドキュメントを使用して、たくさん検索しました;-)
私の間違いは何ですか?スレッドが 1 つしか実行されないのはなぜですか? さらに情報が必要な場合は、お知らせください。
quarkus - ActiveMQ Artemis で期限切れになるメッセージ
Eclipse マイクロプロファイル エミッターを使用して、Quarkus アプリケーションで ActiveMQ Artemis プロデューサーを作成しました。しかし、メッセージはすぐに期限切れになり、に移動されていExpiryQueue
ます。この動作についてはよくわかりません。指定された時間後にのみ有効期限が切れるように、メッセージをキューに保持する方法を提案してください。
以下のコードを使用しています。
メタデータの下に作成:
smallrye-amqp
コネクタを使用しています。の以下のプロパティを追加application.properties
:
java - Mutiny リアクティブプログラミングで長時間実行されているブロッキング void を返すメソッドを呼び出す方法は?
Mutiny の Uni で Async および Sync メソッド呼び出しのチェーンがあります。一部のメソッドは、戻り値の型を持つ長時間実行プロセスvoid
です。
ダウンストリームをブロックせずにそれらを呼び出す/呼び出す適切な方法は何ですか?
以下は、単純な類推コードです。