[GitHub] [rocketmq] zhuyuemufeng edited a discussion: 延时消息写入失败，重新批量写入问题

[via GitHub]

GitHub user zhuyuemufeng edited a discussion: 延时消息写入失败，重新批量写入问题

你好，我对org.apache.rocketmq.store.timer.TimerMessageStore.TimerEnqueuePutService类的逻辑有点疑惑，单个消息写入失败或超时造成整个集合的重新写入，这个造成该批次的定时消息重复，请问这个是基于什么考虑的？代码如下：
![image](https://github.com/apache/rocketmq/assets/51144340/8584f6e6-0dff-485d-b0fb-4e4c9107d251)
为什么不在循环中做状态的判断，只重复投递写入失败的消息呢？


GitHub link: https://github.com/apache/rocketmq/discussions/6959

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org