Spring Integration DSL Kotlin基于消息头路由代码报错排查

错误原因 #

你的代码触发ClassCastException的核心问题是：route方法的lambda参数实际是消息的负载（String类型），但你错误地将它当作Message对象来处理。当你调用it.headers时，相当于强行把String类型的负载转换为Message类型，直接导致类型转换错误。

解决方案 #

要访问消息头，必须确保lambda参数接收的是完整的Message对象，而非仅负载。修改后的代码如下：

.route<Message<String?>, String> { message ->
    when (message.headers["routing_header"] as Int) {
        1 -> "channel_1"
        2 -> "channel_2"
        else -> "nullChannel"
    }
}

额外注意事项 #

如果routing_header实际存储的是String类型（比如外部传入的字符串格式数字），直接强转为Int会引发新的类型转换错误，建议先做安全校验：

.route<Message<String?>, String> { message ->
    val routingValue = message.headers["routing_header"]?.toString()?.toIntOrNull() ?: -1
    when (routingValue) {
        1 -> "channel_1"
        2 -> "channel_2"
        else -> "nullChannel"
    }
}

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