2017-02-16 4 views
2

Java DSLを使用して1つのルートを作成しました。このDSLにはJPAコンポーネントがあり、定期的にDBからレコードをポーリングします。それは良い仕事です。私は各ルートが1つのワーカースレッドを持っていることを望む。 DBがダウンしていたり​​、分のN/Wが発行されていたりすると、ルートは期待通りに機能しません。アプリケーションが実行中です(DBまたはN/Wが稼働してもDBからのポーリング・レコードではありません)。私はワーカースレッドがハングアップしてルートが機能していないと思います。Apache Camel JPAスレッドが掛かった

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またはDBが稼働したらワーカースレッドを再起動するにはどうすればよいですか?

答えて