代码之家 › 专栏 › 技术社区 › Tristan

Spring集成和JPA事务

spring-integration spring-data-jpa spring

Tristan · 技术社区 · 7 年前

我正在使用Spring集成来接收XML形式的XMPP消息:

<int-xmpp:inbound-channel-adapter id="xmppInboundAdapter" channel="xmppInbound" xmpp-connection="xmppConnection" auto-startup="true" />
<int:channel id="xmppInbound" />
<int:service-activator ref="messageRouterService" input-channel="xmppInbound" />

我已经有了一些持久性特性,它可以工作(将消息存储在数据库中,与数据库中的消息进行比较分析,…)。

现在我有了一个方法,它需要是事务性的,因为我需要初始化与1个实体相关的2个集合,所以第二个集合是通过对其调用方法进行延迟初始化的。

这在JUnit中很好,但是我需要做什么才能使它在主代码中工作?我是否可以将@transactional放在任何级别,或者它需要放在整个进程的根目录下,或者甚至在入站适配器中以某种方式声明?

1 回复 | 直到 7 年前

Artem Bilan 7 年前

如果你在JPA和数据库方面的努力真的只是在上面提到的 messageRouterService ,那么用 @Transactional 注释并正确参考 JpaTransactionManager .

如果认为整个流程是事务性的,那么就不可能从 <int-xmpp:inbound-channel-adapter> 因为没有可以注入的钩子 TransactionInterceptor . 但是您可以使用 TransactionInterceptorBuilder(true) 产生 TransactionHandleMessageAdvice 它将通过其 <request-handler-advice-chain> : https://docs.spring.io/spring-integration/docs/5.0.6.RELEASE/reference/html/messaging-endpoints-chapter.html#message-handler-advice-chain

推荐文章

BÅaÅ¼ej Karwowski · 如何处理JmsChannelFactoryBean错误,是否有可能使用自定义错误通道?

7 年前

m.gavr · 在Spring集成中,如何处理拆分后的消息(即使会出现错误)?

7 年前

Klaus Stadler · 在spring集成应用程序中禁用jackson的时区调整

7 年前

Roman · Spring集成:刷新/重新加载动态注册的IntegrationFlow

7 年前

Nick Tsitlakidis · 如何推迟spring集成中的消息消耗

7 年前

kiran reddy · split&aggregate flow中的Spring集成验证

7 年前

Tom · int http的请求-响应延迟时间:出站网关

7 年前

escos · Spring集成-哪种反序列化器用于只有一个起始字节的无限字节流(作为消息的一部分)

7 年前

user55926 · 如何验证使用Spring SFTP下载的文件的校验和

7 年前

user1516815 · 使用带有spring rest模板的Oauth2(授权码)rest api

7 年前