请问一下这里为什么还要执行pushToBucket 扔回zset呢，不是已经在ready queue list准备执行了吗

[zeming-coder]

[ouqiang]

确保消息被成功消费了，如果消费者没有确认，会一直重试。

[zeming-coder]

这样重复插入，需要消费者去重吧！大佬 能够给一个联系方式吗，邮件沟通不是很方便。

…

------------------ 原始邮件 ------------------ 发件人: "qiang.ou"<notifications@github.com>; 发送时间: 2019年5月14日(星期二) 下午5:24 收件人: "ouqiang/delay-queue"<delay-queue@noreply.github.com>; 抄送: "平凡亦是收获"<2550705721@qq.com>;"Author"<author@noreply.github.com>; 主题: Re: [ouqiang/delay-queue] 请问一下这里为什么还要执行pushToBucket 扔回zset呢，不是已经在ready queue list准备执行了吗 (#16) 确保消息被成功消费了，如果消费者没有确认，会一直重试。 — You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub, or mute the thread.

[zeming-coder]

确保消息被成功消费了，如果消费者没有确认，会一直重试。

这个方法是只是给http请求的客户端使用的吧 我看go这边消费没有使用！是类似于PHP这种拉取到期消息消费的吗？这个重复插入会导致客户端重复领取，需要客户端这边去重，删除job pool里面的job才不会重复拉取到这个job的吧

[ouqiang]

请查看README.md文档