Spring Integration：转换器调用后事务配置编译失败问题

编译错误根源 #

编译错误cannot find symbol method transactional(boolean)的直接原因是：handle方法的配置lambda参数e被编译器推断为Object类型，而非Spring Integration DSL期望的GenericEndpointSpec<JpaOutboundGateway>类型。这是因为你在DSL中使用transform(Message.class, this::transform)的写法破坏了类型推断链——指定Message.class作为第一个参数后，DSL无法正确识别转换后的消息类型，导致后续步骤的类型信息丢失。

transform方法的问题 #

你的transform方法签名本身是正确的（接收Message<InputStream>返回Message<MyEntity>），但在DSL中的调用方式有误。不需要显式指定Message.class，Spring Integration DSL可以通过方法引用自动推断输入输出类型。

修复步骤 #

修改DSL中的transform调用，移除Message.class参数，直接使用方法引用：

@Bean
public StandardIntegrationFlow createFlow() {
    return IntegrationFlows
        .from(source())
        .publishSubscribeChannel(pubSub -> pubSub
            .subscribe(sub1 -> sub1
                // 移除Message.class参数，让DSL自动推断类型
                .transform(this::transform)
                .handle(persist(), e -> e.transactional(false))
            )
            .subscribe(sub2 -> sub2 
                .handle(remove())
            )
        )
        .get();
}

额外注意事项 #

• 确保transform方法在转换时保留原始消息的必要头信息（比如SFTP的remoteFile头），这样remove方法才能正确定位并删除远程文件。
• 若需要更明确的类型控制，也可以使用lambda表达式显式声明类型：

  .transform((Message<InputStream> msg) -> this.transform(msg))
  

内容的提问来源于stack exchange，提问作者Christoph Dahlen