問題タブ [smallrye]

RxJava 2 と Reactor には、switchIfEmpty現在のフローに要素がない場合に新しいフローに切り替える like メソッドがあります。

しかし、Minutyを使い始めたとき、Quarkus サンプルを変換して Reactive 機能を使用するときに、代替手段が見つかりません。

現在、私の解決策は次のとおりです。私のPostRepositoryでは、例外を使用して、投稿が見つからないことを示します。

そして、それをキャッチしPostResourceます。

Uniで手段 0 または 1 要素を返す方法、およびlike メソッドPostRepositoryを使用してフローの代替パスを構築する方法は?switchIfEmptyPostResource

AmqpMessages を受信して​​いる Quarkus のアプリがあり、それらを別のトピックに送信します。

smallrye から、メッセージが拒否されたというエラーが表示され続けます。

ここにプロパティがあります

クラス自体

ログ出力:

ご覧のとおり、拒否されたメッセージがあり、これが発生した理由を示す出力はありません。その前に、次のものも検出できます。description='Deliveries cannot be sent to an unavailable address

なぜこれが起こっているのか考えてみてください。これに先立って、同じトピックの JMS 実装があり、正常に動作していました。