我有一个SpringJmsListener
,它从SQS队列接收消息。
现在我需要为我收到的每条消息设置processing_timeout。
假设我将processing_timeout设置为2分钟,那么Jmslistener
接收的每个消息应该在2分钟前完成。如果不是,应该抛出一个异常(这将使SQS立即重新发送)。
如何为每条消息设置这个processing_timeout ?
不进入spring-jms的核心,我能看到的唯一方法是为您的@JmsListener
启动一个工作线程,它可以计时和切碎。