Spring Integration报错：Handler为单向无法配置输出通道，求解决方案

出现“handler是单向MessageHandler”错误的原因是：使用this::mainHandle方法引用且参数为Message<?>时，Spring Integration默认将其包装为单向MethodInvokingMessageHandler，无法直接衔接后续输出通道。以下是三种修改方案：

方案一：使用GenericHandler显式处理 #

通过GenericHandlerlambda表达式明确处理消息并返回结果，让框架识别为非单向handler：

@Bean
public IntegrationFlow flow(PollerMetadata poller, FileReadingMessageSource source){
   return IntegrationFlows.from(source, e->e.poller(poller))
            .handle((GenericHandler<Message<?>>) (message, headers) -> mainHandle(message))
            .channel("somechannel")
            .get();
}

public FileRequest mainHandle(Message<?> message){
       // 原有业务逻辑
       return request;
    }

方案二：修改方法参数为Payload类型 #

由于FileReadingMessageSource的消息payload是File，将mainHandle的参数改为File，方法引用会自动被识别为支持返回值的非单向handler：

@Bean
public IntegrationFlow flow(PollerMetadata poller, FileReadingMessageSource source){
   return IntegrationFlows.from(source, e->e.poller(poller))
            .handle(this::mainHandle)
            .channel("somechannel")
            .get();
}

public FileRequest mainHandle(File file){
       // 基于File构建FileRequest的业务逻辑
       return request;
    }

方案三：在handle配置中直接指定输出通道 #

使用handle的重载方法，通过配置项显式指定输出通道，无需调整原有方法：

@Bean
public IntegrationFlow flow(PollerMetadata poller, FileReadingMessageSource source){
   return IntegrationFlows.from(source, e->e.poller(poller))
            .handle(this::mainHandle, spec -> spec.outputChannel("somechannel"))
            .get();
}

public FileRequest mainHandle(Message<?> message){
       // 原有业务逻辑
       return request;
    }

内容的提问来源于stack exchange，提问作者of32 inc