camel jpa@Consumed未被调用

Question

我试图在jpa实体上使用@Consumed和camel。

这是我的路线：

<route id="incomingFileHandlerRoute"> 
<from
   uri="jpa://com.menora.inbal.incomingFileHandler.Jpa.model.MessageToDB?consumer.nativeQuery=select
    * from file_message where mstatus = 'TODO'&amp;consumer.delay=5000&amp;consumeDelete=false&amp;consumeLockEntity=true&amp;consumer.SkipLockedEntity=true" />
<to uri="bean:incomingFileHandler" />
                    </route>

我的实体：

@Entity
@Table(name = "file_message")
public class MessageToDB implements Serializable {
    /**
     * 
     */
    private static final long serialVersionUID = 1L;
    @Id
    private String uuid;
    private String fileName;
    private String body;
    private String mstatus;
    @Temporal(TemporalType.TIMESTAMP)
    private Date mtimestamp;

    @Consumed
    public void updateMstatus() {
        setMstatus(MessageStatus.DONE.name());
    }

    public String getUuid() {
        return uuid;
    }

    public void setUuid(String uuid) {
        this.uuid = uuid;
    }

    public String getFileName() {
        return fileName;
    }

    public void setFileName(String fileName) {
        this.fileName = fileName;
    }

    public String getBody() {
        return body;
    }

    public void setBody(String body) {
        this.body = body;
    }

    public String getMstatus() {
        return mstatus;
    }

    public void setMstatus(String mstatus) {
        this.mstatus = mstatus;
    }

    public Date getMtimestamp() {
        return mtimestamp;
    }

    public void setMtimestamp(Date mtimestamp) {
        this.mtimestamp = mtimestamp;
    }

}

我确实获得了来自db的结果的incomingFileHandler bean，但我没有获得消费方法updateMstatus。incomingFileHandler bean被连续调用，因为总是有来自db的结果

Answer 1

我在实体中使用camel jpa和注释@consumerd和@preconsumerd实现了类似的功能，但没有调用这些方法。

我查看了camel-jpa源代码，在JpaC中找到了这个onsumer.java：

protected DeleteHandler<Object> createPreDeleteHandler() {
    // Look for @PreConsumed to allow custom callback before the Entity has been consumed
    final Class<?> entityType = getEndpoint().getEntityType();
    if (entityType != null) {
        // Inspect the method(s) annotated with @PreConsumed

如果entityType为null实体类inst检查带有@consumered和@presumerd注释的方法。

解决方案：添加entityType=com。xx。yy。MessageToDB到您的URI以设置endpoint实体类型。