182.9. 使用带有命名查询的消费者
对于仅消耗所选实体,您可以使用 consumer.namedQuery
URI 查询选项。首先,您必须在 JPA Entity 类中定义命名查询:
@Entity @NamedQuery(name = "step1", query = "select x from MultiSteps x where x.step = 1") public class MultiSteps { ... }
@Entity
@NamedQuery(name = "step1", query = "select x from MultiSteps x where x.step = 1")
public class MultiSteps {
...
}
之后,您可以定义一个类似如下的消费者 uri:
from("jpa://org.apache.camel.examples.MultiSteps?consumer.namedQuery=step1") .to("bean:myBusinessLogic");
from("jpa://org.apache.camel.examples.MultiSteps?consumer.namedQuery=step1")
.to("bean:myBusinessLogic");