我用 兔MQ 和 Spring 集成 处理传入的 JSON 消息 .
配置的相关部分如下所示:
<amqp:inbound-channel-adapter channel="incomingChannel" queue-names="..."
message-converter="jsonConverter" error-handler="errorHandler"
error-channel="errorChannel" />
我使用 Jackson Databind 作为 JSON 转换器。
有时传入的 JSON 消息有 语法不正确 .这会导致以下(正确)异常:
org.springframework.amqp.rabbit.listener.ListenerExecutionFailedException: Listener threw exception
Caused by: org.springframework.amqp.support.converter.MessageConversionException: Failed to convert Message content
Caused by: com.fasterxml.jackson.databind.JsonMappingException: Can not deserialize instance of java.lang.String out of START_ARRAY token...
然后由
errorHandler 处理异常。这只是一个
MessagePublishingErrorHandler至
errorChannel .
到现在为止还挺好。问题是，该消息仍然被 AMQP 客户端拒绝，尽管我正在使用错误处理程序处理它。 RabbitMQ 然后一遍又一遍地重新传递消息。即使配置死信队列也无济于事。任何想法如何正确处理这种情况？
处理过程中的异常(成功反序列化后)处理得很好:AMQP 消息已确认并将错误消息发送到
errorChannel .
有任何想法吗？
库版本:
请您参考如下方法:
您可以设置defaultRequeueRejected=false在监听器容器上。
该属性当前未在 channel 适配器上公开，但您可以将容器定义为 <bean... class="...SimpleMessageListenerContainer"/>并使用 listener-container 将其注入(inject)适配器属性。
或者，使用自定义 ErrorHandler抛出 AmqpRejectAndDontRequeueException .
