ActiveMQ中没有更多消息时停止骆驼路线

如果activeMQ中没有更多消息,是否可以使用这种方法来停止骆驼路线?我所需的方案。

  1. activeMQ队列中获取所有消息并进行处理。
  2. 再轮询2-3次以检查是否还有其他新消息,请执行步骤1。
  3. 如果当前没有消息,请停止路由并在5分钟后重新启动(我认为可以通过“轮询策略”实现)。
jianglongdi 回答:ActiveMQ中没有更多消息时停止骆驼路线

看看this answer。它使用调度程序和轮询策略(POJO)轮询队列。

  • 使用计划程序,您可以选择轮询间隔
  • 随着轮询策略使用者的超时,您可以停止使用(例如,如果5秒钟内没有消息到达,则队列可能为空)

如果要完全停止/启动使用者,则可以将Camel Control Bus添加到组合中。然后,您可以启动和停止消费者路线。

本文链接:https://www.f2er.com/2909405.html

大家都在问