diff --git a/app/Amqp/Consumer/DetectionCompleteDelayDirectConsumer.php b/app/Amqp/Consumer/DetectionCompleteDelayDirectConsumer.php index 2c0b91f..e63cae7 100644 --- a/app/Amqp/Consumer/DetectionCompleteDelayDirectConsumer.php +++ b/app/Amqp/Consumer/DetectionCompleteDelayDirectConsumer.php @@ -96,6 +96,8 @@ class DetectionCompleteDelayDirectConsumer extends ConsumerMessage Log::getInstance("queue-DetectionComplete")->error("重新添加队列失败"); return Result::REQUEUE; } + + return Result::DROP; } // 获取医生数据