带有JPA组件、循环和wiretap的Apache Camel引发entitymanger cloesd异常

Question

我有一个关于窃听和jpa-camel组件的问题。我有一个通过窃听拆分的异步路由。在每个路由中，我使用一个jpa生产者来持久化一个实体。问题是，在异步路由到达终点之前，entityManager已关闭。原因是异步路由中使用了相同的entityManager。主路由到达终点并关闭entityManager。

例如，如以下路线：

<route id="mainRoute>
    <from uri="direct:restendpoint"/>
    ...
    <to uri="jpa:MyEntity"/>
    ...
    <loop copy="true">
        ...
        <wireTap uri="direct:asyncroute"/>
    </loop>
</route>

<route id="asyncRoute">
    <from uri="direct:asyncroute"/>
    ...
    <to uri="jpa:MyEntity"/>
    ...
</route>

我认为一个可能的解决方案是检查entitymanager是否为null或已关闭。如果为null或已关闭，请创建新的entitymanager。

public final class JpaHelper {
    ...
    public static EntityManager getTargetEntityManager(Exchange exchange, ...
        ...
        if (em == null || !em.isOpen()) {
            // create a new entity manager
            em = entityManagerFactory.createEntityManager();
        ...
        }
    }
    ...
}

另一个解决方案是窃听。在复制交换的地方，可以删除“CamelEntityManager”属性。

我的快速修复：在异步路由的开始，我从交换中删除了entityManager。

我使用Camel 2.15.2和Spring Boot 1.2.3。释放

有人知道更好的解决方案吗？

Answer 1

这个问题在Camel v.2.16中得到了解决。见文件