Spring Integration int:delayer无回复致重试失效，设置requires-reply=false仍无效

问题根源 #

当int:delayer设置非0延迟时，组件会进入异步调度模式：

• 消息会被存入配置的message-store，由scheduler线程在延迟后执行下游逻辑
• 当前处理线程（chain所在线程）会直接返回，不会向下游router传递消息，导致chain因未收到回复抛出produced no reply for request Message错误，中断正常重试流程

而延迟为0时，delayer是同步执行，直接把消息传给router，chain能拿到回复，所以流程正常。

解决方案 #

1. 给delayer组件直接设置requires-reply="false"

修改delayer的配置，明确告诉组件不需要返回回复：

<int:delayer id="delayRetry" 
             expression="headers['delay']" 
             default-delay="100" 
             ignore-expression-failures="false"
             message-store="adviceRetryMessageStore" 
             scheduler="delayerTaskScheduler"
             requires-reply="false"> <!-- 添加这个配置 -->
    <int:transactional transaction-manager="jdbcTransactionManager" />
</int:delayer>

之前给父组件设置requires-reply="false"无效，是因为错误是由delayer组件本身触发的，需要直接在delayer上配置。

2. 确认重试逻辑的事务边界

delayer的<int:transactional>配置只作用于消息存入message-store的操作，延迟后的消息执行（路由到目标channel）是在调度线程中，不在原事务内。如果重试逻辑依赖事务一致性，需要：

• 给下游的router或后续组件单独配置事务
• 调整重试机制的触发时机，确保在事务上下文内执行

3. 验证延迟表达式的正确性

确保delay头的计算结果始终是合法的整数：

• 检查adviceDelay头是否可能为null或非数值类型，避免表达式计算异常
• 可以给表达式添加更稳妥的默认值兜底，比如：headers.containsKey('SomeVariable')?0:(headers['adviceDelay'] != null ? headers['adviceDelay'] : 1000)*1.2

补充说明 #

Spring Integration的int:delayer在延迟>0时是异步组件，不会同步返回消息，所以在chain这类需要组件回复的容器中，必须显式关闭requires-reply，否则会触发无回复错误。

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