如何避免在pojo中使用驼峰依赖camel示例spring boot rest jpa：

Question

camel示例Spring靴支架jpa

我在看rder.java：

@Consumed
public void setProcessed() {
}

我知道这是必需的，这样Camel就不需要重新处理已处理的订单。然而，如果不向订单添加驼峰依赖项，如何实现这一点呢。爪哇波乔？

原因：在现实生活中，我们需要在不向pojo添加外部依赖的情况下实现相同的功能。

裁判：https://github.com/apache/camel/blob/master/examples/camel-example-spring-boot-rest-jpa/src/main/java/org/apache/camel/example/spring/boot/rest/jpa/Order.java

编辑1：按照克劳斯的建议，创建了一个自定义删除处理器

public class OrderProcessedHandler implements DeleteHandler<Order>{
    @Override
    public void deleteObject(EntityManager arg0, Object arg1, Exchange arg2) {
        ((Order) arg1).setProcessed(true);
    }
}

并在endpointuri中指定：

    // A second route polls the DB for new orders and processes them


from("jpa:sb.app.bo.Order" 
+ "?consumer.namedQuery=new-orders"
+ "&consumer.delay={{example.processOrderPeriod:25s}}"
+ "&consumeDelete=false"
+ "&deleteHandler=sb.app.camel.routes.OrderProcessedHandler")
.routeId("process-order")
.log("Processed order #id ${body.id} with ${body.amount} ");

无法使用处理程序，错误日志：

2017-10-31 15:45:33.688 ERROR 1429 --- [  restartedMain] o.s.boot.SpringApplication               : Application startup failed

org.apache.camel.RuntimeCamelException: org.apache.camel.FailedToCreateRouteException: Failed to create route process-order: Route(process-order)[[From[jpa:sb.app.bo.Order?consumer.name... because of Failed to resolve endpoint: jpa://sb.app.bo.Order?consumeDelete=false&consumer.delay=25s&consumer.namedQuery=new-orders&deleteHandler=sb.app.camel.routes.OrderProcessedHandler due to: Could not find a suitable setter for property: deleteHandler as there isn't a setter method with same type: java.lang.String nor type conversion possible: No type converter available to convert from type: java.lang.String to the required type: org.apache.camel.component.jpa.DeleteHandler with value sb.app.camel.routes.OrderProcessedHandler
    at org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1831) ~[camel-core-2.20.0.jar:2.20.0]
    at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:136) ~[camel-spring-2.20.0.jar:2.20.0]
    at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:174) ~[camel-spring-2.20.0.jar:2.20.0]

解决方案（基于@claus建议）：

// A second route polls the DB for new orders and processes them
from("jpa:sb.app.bo.Order"  //select * from orders where consumed = false
    + "?consumer.namedQuery=query_new_orders"
    + "&consumer.delay={{example.processOrderPeriod:5s}}"
    + "&consumeDelete=false"
    + "&deleteHandler=#orderProcessedMarker")
    .routeId("process-order")
    .log("Processed order #id ${body.id} with ${body.amount} copies of the «${body.book.description}» book");

DeleteHandler bean：

@Bean(name = "orderProcessedMarker")
public DeleteHandler<Order> createOrderProcessHandler() {
    return new DeleteHandler<Order>() {
        @Override
        public void deleteObject(EntityManager arg0, Object arg1, Exchange arg2) {
            ((Order) arg1).setProcessed(true);
        }
    };
}

Answer 1

您可以使用可以在JPAendpoint上配置的自定义deleteHandler而不是使用@消耗。

>

https://github.com/apache/camel/blob/master/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/DeleteHandler.java

https://github.com/apache/camel/blob/master/components/camel-jpa/src/main/docs/jpa-component.adoc