【发布时间】:2014-06-27 17:59:46
【问题描述】:
我有一个场景,如果端点关闭,ActiveMQ 存储将消息排入队列,并且我尝试在接收到新请求时重新传递所有排入队列的消息。因此,最新消息将是最后一个要处理的消息。如果端点仍处于关闭状态,则最新消息也会入队,如果收到新消息,该进程将再次启动。
我在使用这种方法时遇到的问题是,如果在我弹出消息并重新尝试处理时端点仍然关闭,那么最终可能会出现无序队列,因为消息将重新插入到而是队列(例如从 MSG1、MSG2 到 MSG2、MSG1)。
到目前为止,我考虑在弹出之前添加服务器状态检查,但我很想知道是否有其他方法可以解决这个问题,或者我是否只是错误地处理了重新传递方法。
【问题讨论】:
标签: jms mule message-queue mule-studio