此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring AMQP 3.2.6spring-doc.cadn.net.cn

消费者活动

每当侦听器 (消费者)经历了某种失败。 活动ListenerContainerConsumerFailedEvent具有以下属性:spring-doc.cadn.net.cn

  • container:使用者遇到问题的侦听器容器。spring-doc.cadn.net.cn

  • reason:失败的文本原因。spring-doc.cadn.net.cn

  • fatal:指示故障是否致命的布尔值。 在非致命异常的情况下,容器会尝试重新启动使用者,根据recoveryIntervalrecoveryBackoff(对于SimpleMessageListenerContainer) 或monitorInterval(对于DirectMessageListenerContainer).spring-doc.cadn.net.cn

  • throwable:这Throwable那被抓住了。spring-doc.cadn.net.cn

这些事件可以通过实现ApplicationListener<ListenerContainerConsumerFailedEvent>.spring-doc.cadn.net.cn

系统范围的事件(例如连接失败)由所有使用者发布,当concurrentConsumers大于 1。

如果使用者失败,因为默认情况下,如果其队列被独占使用,以及发布事件,则DEBUG日志(从 3.1 开始,以前是 WARN)。 要更改此日志记录行为,请提供自定义ConditionalExceptionLoggerAbstractMessageListenerContainer实例的exclusiveConsumerExceptionLogger财产。 此外,SimpleMessageListenerContainer默认情况下,此类异常后的消费者重新启动现在记录在 DEBUG 级别(以前是 INFO)。 一种新方法logRestart()已添加到ConditionalExceptionLogger以允许更改此设置。spring-doc.cadn.net.cn

此外,AbstractMessageListenerContainer.DefaultExclusiveConsumerLogger现在是公共的,允许它被子类化。spring-doc.cadn.net.cn

致命错误始终记录在ERROR水平。 这是不可修改的。spring-doc.cadn.net.cn

其他几个事件在容器生命周期的各个阶段发布:spring-doc.cadn.net.cn