Kotlin挂起函数作为泛型Spring Integration Service Activator的类型问题

Spring运行时的泛型擦除导致无法正确推断Message<T>中T的实际类型，再加上Kotlin挂起函数会被编译为返回Mono的形式，框架误将Mono实例当成了Message的负载，而非预期的String。当直接声明Message<String>时，具体类型未被擦除，框架能准确识别负载类型。

提供两种可行的解决方式，按需选择：

方式1：拆分Message参数为Payload和Headers（推荐） #

将接口中的Message<T>参数拆分为@Payload注解标注的泛型参数，让Spring Integration直接识别负载类型，避免泛型擦除的干扰：

interface WorkflowStep<T, E> {

    @ServiceActivator
    suspend fun handle(@Payload payload: T): E {
        // 若需要Message的其他属性，可添加@Headers headers: Map<String, Any>参数
        val message = MessageBuilder.withPayload(payload).build()
        // 前置处理逻辑
        return stepLogic(message)
    }

    suspend fun stepLogic(message: Message<T>): E
}

修改后，IntegrationFlow的调用无需调整，框架能正确解析T的实际类型（如String）。

方式2：在IntegrationFlow中显式指定输入类型 #

如果需要保留Message<T>作为入参，可在构建IntegrationFlow时，通过TypeDescriptor显式告知框架泛型的实际类型：

// 创建对应Message<String>的TypeDescriptor
val messageType = TypeDescriptor.generic(
    Message::class.java,
    TypeDescriptor.valueOf(String::class.java)
)

// 在handle调用中指定输入类型
IntegrationFlow.from(/* 输入通道 */)
    .handle(exampleStep, "handle") { spec ->
        spec.inputType(messageType)
    }
    // 后续流程
    .get()

通过inputType方法明确输入类型，框架就能正确解析Message的负载类型，而非误识别为MonoOnErrorResume。

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