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;