delay-queue icon indicating copy to clipboard operation
delay-queue copied to clipboard

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

Open zeming-coder opened this issue 6 years ago • 4 comments

image

zeming-coder avatar May 14 '19 03:05 zeming-coder

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

ouqiang avatar May 14 '19 09:05 ouqiang

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

------------------ 原始邮件 ------------------ 发件人: "qiang.ou"[email protected]; 发送时间: 2019年5月14日(星期二) 下午5:24 收件人: "ouqiang/delay-queue"[email protected]; 抄送: "平凡亦是收获"[email protected];"Author"[email protected]; 主题: 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 avatar May 14 '19 09:05 zeming-coder

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

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

zeming-coder avatar May 14 '19 09:05 zeming-coder

请查看README.md文档

ouqiang avatar May 14 '19 10:05 ouqiang