From be84b6500806b5783209597e31ee178ea2f56349 Mon Sep 17 00:00:00 2001 From: wucongxing8150 <815046773@qq.com> Date: Thu, 18 Apr 2024 16:55:18 +0800 Subject: [PATCH] 1 --- app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php b/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php index 5c137af..eebd6e9 100644 --- a/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php +++ b/app/Amqp/Consumer/UserCouponExpiredDelayDirectConsumer.php @@ -87,7 +87,7 @@ class UserCouponExpiredDelayDirectConsumer extends ConsumerMessage $res = $producer->produce($message); if (!$res) { Log::getInstance("queue-UserCouponExpired")->error("未到过期时间,重新添加队列失败"); - return Result::REQUEUE; + return Result::DROP; } return Result::DROP;