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