1

src/Mq/MqConsumeInterface.php

@@ -117,6 +117,7 @@ abstract class MqConsumeInterface
             } catch (\Throwable $exception) {
                 $this->exceptionHandle($exception);
                 $rabbitMq->resetQueue($consumeParamBean->getQueueName(), $consumeParamBean->getRouteKey());
+                sleep(2);
             }
         }
     }