延时消息写入失败，重新批量写入问题

[zhuyuemufeng]

你好，我对org.apache.rocketmq.store.timer.TimerMessageStore.TimerEnqueuePutService类的逻辑有点疑惑，单个消息写入失败或超时造成整个集合的重新写入，这个造成该批次的定时消息重复，请问这个是基于什么考虑的？代码如下：

为什么不在循环中做状态的判断，只重复投递写入失败的消息呢？