Apache Camel JPA 线程挂起
Apache Camel JPA Thread Hung
我已经使用 Java DSL 创建了一个路由,它具有 JPA 组件以定期从数据库中轮询记录。它运作良好。我希望每条路线都有一个工作线程。如果 DB 关闭或任何 N/W 分钟的问题,路由未按预期工作。应用程序是 运行。(即使在 DB 或 N/W 启动后,它也不会从 DB 轮询记录)。我认为工作线程挂起并且路由不工作。
SimpleRegistry registry = new SimpleRegistry();
registry.put("datasource",myDataSourceObj);
CamelContext context = new DefaultCamelContext(registry);
context.addRoutes(new myRouteBuilder());
from URI= "uri="jpa://br.rafaeltuelho.model.Customer?consumer.namedQuery=Customer.findAll&consumer.delay=30000&consumeDelete=true"
请任何人帮我解决这个问题。
如何避免这个工作线程挂起?
如何在 N/W 或数据库启动后重新启动工作线程?
在 JPA URI 中添加 2 个参数后。 DB 启动后它运行良好。
+ "&sharedEntityManager=true"
+ "&joinTransaction=false"
我已经使用 Java DSL 创建了一个路由,它具有 JPA 组件以定期从数据库中轮询记录。它运作良好。我希望每条路线都有一个工作线程。如果 DB 关闭或任何 N/W 分钟的问题,路由未按预期工作。应用程序是 运行。(即使在 DB 或 N/W 启动后,它也不会从 DB 轮询记录)。我认为工作线程挂起并且路由不工作。
SimpleRegistry registry = new SimpleRegistry();
registry.put("datasource",myDataSourceObj);
CamelContext context = new DefaultCamelContext(registry);
context.addRoutes(new myRouteBuilder());
from URI= "uri="jpa://br.rafaeltuelho.model.Customer?consumer.namedQuery=Customer.findAll&consumer.delay=30000&consumeDelete=true"
请任何人帮我解决这个问题。 如何避免这个工作线程挂起? 如何在 N/W 或数据库启动后重新启动工作线程?
在 JPA URI 中添加 2 个参数后。 DB 启动后它运行良好。
+ "&sharedEntityManager=true"
+ "&joinTransaction=false"