Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

59.16. 使用基于 JPA 的 Idempotent 存储库

EIP 模式中的 Idempotent Consumer 用于过滤重复的消息。提供了基于 JPA 的幂等存储库。

使用基于 JPA 的幂等存储库：

流程

  1. 在 persistence.xml 文件中设置 persistence-unit。
  2. 设置 org.springframework.orm.jpa.JpaTemplate，它由 org.apache.camel.processor.idempotent.jpa.JpaMessageIdRepository 使用。
  3. 配置错误格式化宏： snippet: java.lang.IndexOutOfBoundsException: Index: 20, Size: 20
  4. 将 idempotent 存储库配置为 org.apache.camel.processor.idempotent.jpa.JpaMessageIdRepository。
  5. 在 Spring XML 文件中创建 JPA idempotent 存储库，如下所示： 
<camelContext xmlns="http://camel.apache.org/schema/spring">
    <route id="JpaMessageIdRepositoryTest">
        <from uri="direct:start" />
        <idempotentConsumer idempotentRepository="jpaStore">
            <header>messageId</header>
            <to uri="mock:result" />
        </idempotentConsumer>
    </route>
</camelContext>
Copy to Clipboard Toggle word wrap

在 IDE 中运行此 Camel 组件测试时

如果您在 IDE 中直接运行此组件 的测试，而不是通过 Maven 运行，则您可能会看到类似以下的例外： 

org.springframework.transaction.CannotCreateTransactionException: Could not open JPA EntityManager for transaction; nested exception is
<openjpa-2.2.1-r422266:1396819 nonfatal user error> org.apache.openjpa.persistence.ArgumentException: This configuration disallows runtime optimization,
but the following listed types were not enhanced at build time or at class load time with a javaagent: "org.apache.camel.examples.SendEmail".
    at org.springframework.orm.jpa.JpaTransactionManager.doBegin(JpaTransactionManager.java:427)
    at org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java:371)
    at org.springframework.transaction.support.TransactionTemplate.execute(TransactionTemplate.java:127)
    at org.apache.camel.processor.jpa.JpaRouteTest.cleanupRepository(JpaRouteTest.java:96)
    at org.apache.camel.processor.jpa.JpaRouteTest.createCamelContext(JpaRouteTest.java:67)
    at org.apache.camel.test.junit5.CamelTestSupport.doSetUp(CamelTestSupport.java:238)
    at org.apache.camel.test.junit5.CamelTestSupport.setUp(CamelTestSupport.java:208)
Copy to Clipboard Toggle word wrap

这里的问题在于，源是通过 IDE 编译或重新编译，而不是通过 Maven 编译 ，这会在构建时增强字节代码。要克服这一问题，您需要启用 Open JPA 的动态字节代码增强。例如，假设 Camel 中使用的当前 Opengfortran 版本为 2.2.1，以便在 IDE 中运行测试，您需要将以下参数传递给 JVM： 

-javaagent:<path_to_your_local_m2_cache>/org/apache/openjpa/openjpa/2.2.1/openjpa-2.2.1.jar
Copy to Clipboard Toggle word wrap
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat