java - 使用 RxJavaErrorHandler 进行全局错误处理

Question

我有以下引发异常并希望在全局级别捕获该异常的方法

public Maybe<FindProductCommand> get(ProductSearchCriteriaCommand searchCriteria) {
        LOG.info("Controller --> Finding all the products");
        return iProductManager.find(searchCriteria);
    }

根据 reactx 文档http://reactivex.io/documentation/plugins.html

为此，请扩展class RxJavaErrorHandler并覆盖此方法：

void handleError(Throwable e)

我正在使用带有 java 的 micronaut 应用程序并具有以下依赖项

implementation("io.micronaut.rxjava3:micronaut-rxjava3")

并尝试了下面的代码

public class RxJavaExceptionHandler extends RxJavaErrorHandler{
}

无法导入 RxJavaErrorHandler

在寻找解决方案时，许多示例中都使用了以下代码

RxJavaPlugins.getInstance().registerErrorHandler(new RxJavaErrorHandler() {
        @Override
        public void handleError(Throwable e) {
            Timber.e(e.toString());
        }
    });

但是，在 RxJavaPlugins 中找不到 getInstance().registerErrorHandler