问题描述
我有一个从 SQS 队列接收消息的 Spring JmsListener
。
现在我需要为我收到的每条消息设置 processing_timeout。
假设我已将 processing_timeout 设置为 2 分钟,那么 Jmslistener
收到的每条消息都应在 2 分钟前完成。如果不是,则应抛出异常(这将使 SQS 立即重新发送)。
如何为每条消息设置此 processing_timeout?
解决方法
无需深入了解 spring-jms,我能看到的唯一方法是让您的 @JmsListener
启动一个工作线程,以便它可以计时和砍伐。