🚀feat(consumer) add exception handling for AMQPTimeoutException (#6391)

hyperf · Dec 15, 2023 · dae5588 · dae5588
1 parent de0a823
commit dae5588
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Consumer.php b/src/Consumer.php
@@ -84,7 +84,7 @@ function (AMQPMessage $message) use ($consumerMessage, $concurrent) {
                     if ($maxConsumption > 0 && ++$currentConsumption >= $maxConsumption) {
                         break;
                     }
-                } catch (AMQPTimeoutException $exception) {
+                } catch (AMQPTimeoutException) {
                     $this->eventDispatcher?->dispatch(new WaitTimeout($consumerMessage));
                 } catch (Throwable $exception) {
                     $this->logger->error((string) $exception);
@@ -192,7 +192,7 @@ protected function getCallback(ConsumerMessageInterface $consumerMessage, AMQPMe
                 return;
             }
             if ($result === Result::NACK) {
-                $this->logger->debug($deliveryTag . ' uacked.');
+                $this->logger->debug($deliveryTag . ' nacked.');
                 $channel->basic_nack($deliveryTag, false, $consumerMessage->isRequeue());
                 return;
             }