MessageHandler抛异常时AMQ未返回消息问题求助

这个问题的核心在于Spring Integration的JMS消息驱动端点和GCP PubSub的异常处理策略完全不同。咱们一步步拆解原因和解决办法：

为什么PubSub能自动放回消息，AMQ不行？ #

GCP PubSub的Spring集成实现中，当MessageHandler#handleMessage抛出异常时，框架会自动对消息执行Nack（否定确认），直接触发消息重回队列。但你当前的AMQ配置里，ChannelPublishingJmsMessageListener的默认行为是：只要成功把消息发送到inputChannel，就会自动确认消息——哪怕后续MessageHandler处理时抛出异常，listener已经完成了自己的投递职责，所以消息会被确认，不会回到队列。

解决办法：让异常传播回JMS Listener，触发消息回滚/不确认 #

你需要调整两个关键配置，让handler的异常能影响到JMS会话的确认逻辑：

1. 修改JMS Listener容器的确认模式 #

把SimpleMessageListenerContainer的确认模式改为客户端确认或开启事务会话，这样消息不会被自动确认，必须手动确认或异常时回滚：

SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setDestinationName("my-subscription");
// 方案A：使用客户端确认模式，异常时不确认消息
container.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
// 方案B：开启事务（更推荐，异常时自动回滚会话）
container.setSessionTransacted(true);

2. 配置ChannelPublishingJmsMessageListener传播异常 #

默认情况下，ChannelPublishingJmsMessageListener会捕获MessageHandler的异常并发送到errorChannel（如果配置了），但不会把异常传播回listener的onMessage方法。你需要开启propagateException，让异常透传回去，触发JMS会话的回滚/不确认：

ChannelPublishingJmsMessageListener listener = new ChannelPublishingJmsMessageListener();
// 开启异常传播，让handler的异常回到listener的onMessage方法
listener.setPropagateException(true);
// 可选：配置errorChannel，用于自定义异常处理（比如重试、死信队列）
listener.setErrorChannel(errorChannel());

3. （可选）定义Error Channel处理异常 #

如果需要对异常做更细粒度的控制（比如限制重试次数、投递到死信队列），可以定义一个errorChannel和对应的处理器：

@Bean
public MessageChannel errorChannel() {
    return new DirectChannel();
}

@Bean
@ServiceActivator(inputChannel = "errorChannel")
public MessageHandler errorHandler() {
    return message -> {
        // 获取原始异常和消息
        MessagingException exception = (MessagingException) message.getPayload();
        Message<?> originalMessage = exception.getFailedMessage();
        
        // 在这里实现自定义逻辑：比如记录告警日志、发送到死信队列等
        // 如果需要让消息重回队列，只需要确保异常被传播回listener即可（上面的propagateException=true已经处理）
    };
}

验证调整后的流程 #

当你完成上述配置后：

1. JMS Listener接收到消息，发送到myChannel
2. CustomHandler处理消息时抛出异常
3. 异常被传播回ChannelPublishingJmsMessageListener的onMessage方法
4. 如果开启了事务，会话会回滚；如果是客户端确认模式，listener不会确认消息
5. AMQ会把未确认/回滚的消息重新投递到队列

内容的提问来源于stack exchange，提问作者Kannan Ramamoorthy