事务提交/回滚不在spring集成通道适配器上

Question

我正在使用spring integration来设置消息流。我从一个目录中读取文件，并对它们做一些事情。我已经在入站通道适配器上设置了一个poller，其中包括事务管理器和同步工厂。同步工厂将after-commit和after-rollback推送到通道，这些通道将原始文件推送到成功或失败文件夹。这一切都很好。

现在的问题是，当处理一些文件时，它们可能会产生新的消息，我想通过同样的过程循环。我不希望这些新文件涉及到原始文件的事务，但我希望它们有自己的事务上下文。

我试过用多种方法剥这只猫的皮来让它工作。我所得到的最接近的方法是创建一个新消息，并使用网关将其推送到起始通道（通过异步调用以终止事务）-然而，由于事务定义位于文件入站通道适配器上，新消息没有得到事务性支持，因此无论它们通过还是失败，都不会被推送到适当的文件夹。

这是正确的架构，还是有一个我不知道应该使用的模式？

（另外，我不只是将新文件写入适配器轮询的原始目录的原因是，我希望包含一个指向父文件的头文件。因此，我必须创建一条消息）。

任何想法都将不胜感激。

Answer 1

@messaginggateway方法可以用@async和@transactional标记。因此，对这样一个子流的调用将发生在带有自己事务的另一个线程上。或者，您可以添加propagation=propagation.requires_new来代替@async。因此，子流将启动自己的事务，包装事务将被挂起。

我将在@messaginggateway调用周围使用try...catch实现oncommit/onrollback。