在 Flux/Mono 反应式管道之外抛出异常

如何解决在 Flux/Mono 反应式管道之外抛出异常

在我的 spring JMS 侦听器 onMessage 方法中，我使用如下反应式管道，我从队列接收 JMS 消息并将其转换为不同的格式并发布到另一个主题。如果没有反应流，在输出发布失败的情况下，我可以抛出一个运行时异常，以从队列中重新传递相同的消息。但是通过使用下面的反应式方法流程，我找不到在外面抛出异常的方法。你能帮忙看看这里应该用什么方法来抛出异常以获得重新传递的消息

    public void onMessage(Message message) {
      Mono.just(message)
     .doOnNext(LoggingUtil::logMessage)
     .flatMapIterable(messageTransformer::transformToTriggerEvents)
     .doOnNext(LoggingUtil::logTriggerEvent)
     .doOnNext(triggerEventPublisher::publish)
     .subscribe();                                                                                    
    }