使用camel指定从activemq队列读取消息的超时

Question

我正在使用camel从activemq队列中读取消息，对其进行处理并将其发布到另一个队列中。路线如下所示：

from("jms:incoming.queue") 
.process(new MyProcessor()) 
.to("jms:outgoing.queue"); 

我需要是否有“incoming.queue”超过3分钟内没有消息指定超时这样，我想停止路线。我可以使用OnCompletion（），但它会在每条消息之后调用。我可以指定发送消息到“outgoing.queue”的超时时间。有没有一种方法可以指定超时时间，如果在“incoming.queue”中没有超过3分钟的消息，我可以停止路由？

在此先感谢您的帮助。

Answer 1

根据上面的评论，看起来你只是想按计划开始和停止路线。您可以使用石英作业来调用jms路径上的开始和停止方法。如果你喜欢，你甚至可以使用石英端点来制作石英逻辑。

我能想到的

Answer 2

两个选项...

1. 使用CronScheduledRoutePolicy启动/在指定时间自动停止路线......

   CronScheduledRoutePolicy myPolicy = new CronScheduledRoutePolicy(); 
   myPolicy.setRouteStartTime("0 20 * * * ?"); 
   myPolicy.setRouteStopTime("0 0 * * * ?"); 
   
   from("jms:incoming.queue") 
       .routePolicy(myPolicy).noAutoStartup() 
       .process(new MyProcessor()) 
       .to("jms:outgoing.queue");   
   

2. 使用骆驼石英路线和一个polling consumer按计划排空队列

   MyCoolBean cool = new MyCoolBean(); 
   cool.setProducer(template); 
   cool.setConsumer(consumer); 
   
   from("quartz://myGroup/myTimerName?cron=0+20+*+*+*+?") 
       .bean(cool); 
   
   //MyCoolBean snippet 
   while (true) { 
       // receive the message from the queue, wait at most 60s 
       Object msg = consumer.receiveBody("jms:incoming.queue", 60000); 
       if (msg == null) { 
        break; 
       } 
       producer.sendBody("jms:outgoing.queue", msg); 
   }