JPAコンポーネントを使用して簡単なルートを作成しました
`fromF("jpa:%s?consumer.namedQuery=step1&delay=5s&consumeDelete=false&consumeLockEntity=false", Event.class.getName())
.log("Query Fired")
.process(exchange -> System.out.println(exchange.getIn().getBody()))
.end();
コンソールで、クエリが起動されているのを見ることができます
Hibernate: select event0_.eventId as eventId1_3_, event0_.event_desc as event_desc2_3_, event0_.event_name as event_name3_3_, event0_.event_type as event_type4_3_, event0_.valid_from_date as valid_from_date5_3_, event0_.insight as insight6_3_, event0_.is_processed as is_processed7_3_, event0_.severity as severity8_3_, event0_.source_system_name as source_system_name9_3_, event0_.valid_to_date as valid_to_date10_3_ from OV90PLFM.event event0_ where event0_.is_processed=0
しかし、この後、ログが印刷されているのを見ることができず、プロセッサも実行されていません。遅延の後、クエリは発火し続けますが、例外はなく、ルート処理は完了しません。ログは印刷されておらず、プロセッサも呼び出されていません。ログレベルを変更しましたが、まだ例外はありません。
ルートの実行を完了して、プロセッサに何かを書き込めるようにしたいだけです。
同じクエリで、データベース内のすべての行が得られます。
何が問題なのか教えてください。