阿帕奇骆驼优雅路线关闭
我有一个Camel route，它使用队列中的消息并将消息存储到数据库中。现在，我想以一种优雅的方式手动关闭运行骆驼路线。我有一个RestEndpoint，每当我需要停止Camel route时就会被触发。此endpoint应停止路由。但是，如果在关闭期间有任何正在运行的消息或事务，则必须在不消耗来自camel route的("")endpoint的任何新消息的情况下成功完成，并在完成正在运行的消息或事务后关闭。谁能帮助我，我如何编码？
共有2个答案
shutdownRunningTask(ShutdownRunningTask.CompleteCurrentTaskOnly)
以下是控制/监控骆驼路线的几个选项
>
CamelContext API的
控制总线组件
JMX API的
您可以通过以下两个网站开始
http://camel.apache.org/controlbus.html
https://dzone.com/articles/apache-camel-monitoring
-
我有一个spring boot应用程序，我正在向其中添加一个camel路由。定义路由的类扩展了FatJarRouter，并用@component注释。当应用程序作为spring boot应用程序运行时，不会识别路由。但是，如果我在主类中使用@SpringBootApplication注释编写路由，则会标识路由。这是它目前在日志中的显示方式： 请告诉我如何在将路由作为一个单独的类而不是在主类中编写时
-
我试图使用Apache Camel Quartz2实现一个调度器，它每分钟执行一次路由，并按预期执行一些任务。我使用spring DSL实现与apache camel相关联的路由，如下所示： 根据日志，它不会记录为路由记录的消息，例如Direct:DomainsWithFTPUsers等等。请指导如何实现同样的目标。
-
遵循官方文件(https://camel.apache.org/manual/component-dsl.html#_using_component_dsl)我创建了以下代码： 但是中的告诉我： 并且中的特性不建议导入相应的库。 有人能给我指出正确的方向吗？ 我必须理解的概念才能做到这一点吗？
-
我们需要的是直接的API来设置和使用集群消息队列。我们最初的计划是使用Camel在集群JMS或ActiveMQ队列上进行消费/生产。Kafka如何使这项任务变得更容易？在任何一种情况下，应用程序本身都将在WebLogic服务器上运行。 消息传递将是点对点类型，其中有多个相同服务的实例在运行，但根据负载平衡策略，只有一个实例应该处理消息并发出结果。消息队列也是群集的，因此服务实例或队列实例的失败都不
-
考虑到apache Camel，我有一个问题：是否可以通过代码来创建全局拦截器，例如AOP？拦截器应该跳过endpoint还是模仿endpoint？ 提前致谢
-
下面是我试图实现的场景： 谢谢你的帮助。此外，这里是已经工作的FTP部分。