1

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

しかし、この後、ログが印刷されているのを見ることができず、プロセッサも実行されていません。遅延の後、クエリは発火し続けますが、例外はなく、ルート処理は完了しません。ログは印刷されておらず、プロセッサも呼び出されていません。ログレベルを変更しましたが、まだ例外はありません。

ルートの実行を完了して、プロセッサに何かを書き込めるようにしたいだけです。

同じクエリで、データベース内のすべての行が得られます。

何が問題なのか教えてください。

4

0 に答える 0