我一直从Queue1接收所有的JMS消息,并试图处理它。
如果我尝试处理5次,并回滚了5次,我希望ActiveMQ在一段时间内(例如5分钟)将消息放到不同的队列中。
我怎样才能做到这一点呢?
发布于 2013-04-23 17:52:14
您可以向类似消息的RESUBMIT_TIMES添加自定义属性,并递增该属性,直到达到5为止。请阅读:JMS
如果达到5,则将其移动到5分钟队列,方法是在那里设置另一个具有当前时间戳的属性。例如:
message.setStringProperty("TimeOfDispatch", LocalDate.now().toString("yyyy-MM-dd hh:MM:ss"));让另一个消费者在5分钟队列中检查5分钟是否已经过去(通过使用标题中的时间检查当前时间)
https://stackoverflow.com/questions/16166054
复制相似问题