处理使用者异常Rabbit MQ Micronaut 2.2.1
尝试在Micronaut 2.2.1中实现处理使用者异常https://micronaut-projects.github.io/micronaut-rabbitmq/latest/guide/#consumerexceptions
按照文件规定
@Singleton
@Primary
public class RabbitListenerExceptionHandler implements io.micronaut.rabbitmq.exception.RabbitListenerExceptionHandler {
private static final Logger LOG = LoggerFactory.getLogger(RabbitListenerExceptionHandler.class);
@Override
public void handle(RabbitListenerException exception) {
if (LOG.isErrorEnabled()) {
Optional<RabbitConsumerState> messageState = exception.getMessageState();
if (messageState.isPresent()) {
LOG.error("Error processing a message for RabbitMQ consumer [" + exception.getListener() + "]", exception);
} else {
LOG.error("RabbitMQ consumer [" + exception.getListener() + "] produced an error", exception);
}
}
}
}
Caused by: io.micronaut.context.exceptions.NonUniqueBeanException: Multiple possible bean candidates found: [io.micronaut.rabbitmq.exception.DefaultRabbitListenerExceptionHandler, fete.bird.common.extension.RabbitListenerExceptionHandler]
共有1个答案
您必须用@replaces(defaultraBitListenerExceptionHandler.class)替换默认实现
-
我有一个循环缓冲区（数组/先进先出），一个消费者和一个生产者。生产者将随机数放入数组中，消费者获取第一个数字并检查它是否是相对素数。 我的代码工作正常，我认为它工作正常，但我想改进它。我不太确定我的“空运行”方法。我应该在其他地方做异常处理吗？改变“无限循环”？不应更改方法签名（它们是预定义的）。 我会很高兴每一个改进代码的建议。(不在乎知名度(公开，...)，还有静态的东西，我刚刚把它们放在一个
-
问题内容： 这是处理生成器中引发的异常的后续操作，并讨论了一个更一般的问题。 我有一个功能，可以读取不同格式的数据。所有格式都是面向行或记录的，每种格式都有一个专用的解析功能，可以作为生成器来实现。因此，主读取函数获得一个输入和一个生成器，该生成器从输入中读取其各自的格式并将记录传递回主函数： 哪里是这样的： 我面临的问题是，尽管可能引发异常（例如，从流中读取时），但它不知道如何处理它。负责处理异
-
我使用JPA和Hibernate作为容器管理事务的提供者（JBossAS 6.1.0.Final）。 我正在尝试实现一些细粒度的异常处理，因为我的应用程序上有一个特定的异常层次结构，所以我可以定义在任何情况下要做什么。因此，我已经研究了几个小时，发现文档很模糊，示例也有些原始，因为“为了清晰起见”总是忽略异常处理，或者是一个简单的try-catch块，用于处理异常e。 例如，采用以下代码： cat
-
我有代码： 处理消费者异常的最佳方法是什么？现在，如果异常引发，它将被吞没。。。
-
我不知道该怎么办。 当我试图从解析器获取语法错误的数量时，它显示0。 编辑： 它返回null。
-
Blade 内置了 异常处理器，在开发者模式下它会将异常输出在前端页面，并在控制台打印堆栈信息，生产环境只打印在控制台。 有些时候不满足我们的需求，这时候就需要自定义异常处理了，比如针对某个自定义的异常进行特殊处理。 我们用一个例子来解释如何操作。 定义了一个名为 TipException 的运行时异常类，用于输出错误消息到前台。 按照上面对异常的处理情况这个异常的堆栈信息会被输出在控制台，生产环