workbunny / webman-rabbitmq

🚀🐇 A PHP implementation of RabbitMQ Client for webman plugin.
https://www.workerman.net/plugin/67
MIT License
23 stars 4 forks source link

请问一下,如何实现重试次数呢? #8

Closed imlinfly closed 1 year ago

chaz6chez commented 1 year ago

不好意思,没有太明白需求点; 是要是实现重试次数的阈值设置吗?比如重试5次后抛弃消息? 如果是要实现重试后抛弃消息这种需求的话,我建议在消费者handler中自行实现,通过每次抛入队列后增加一个count计数即可实现

imlinfly commented 1 year ago

不好意思,没有太明白需求点; 是要是实现重试次数的阈值设置吗?比如重试5次后抛弃消息? 如果是要实现重试后抛弃消息这种需求的话,我建议在消费者handler中自行实现,通过每次抛入队列后增加一个count计数即可实现

感谢回复,已经解决了

重试5次后抛弃消息,设置以下参数即可。

$message->setArguments(
    array_merge($message->getArguments(), [
        'x-queue-type' => 'quorum',
        'x-delivery-limit' => 5,
    ])
);