From cf2c6e818090ca02b2a53e545405a13a25e44f2a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=A9r=C3=A9my=20Deruss=C3=A9?= Date: Thu, 14 Oct 2021 10:04:25 +0200 Subject: [PATCH] Lower log level in case of retry --- .../SendFailedMessageForRetryListener.php | 14 +------------- 1 file changed, 1 insertion(+), 13 deletions(-) diff --git a/src/Symfony/Component/Messenger/EventListener/SendFailedMessageForRetryListener.php b/src/Symfony/Component/Messenger/EventListener/SendFailedMessageForRetryListener.php index bd42cebcc5f14..90146c342f333 100644 --- a/src/Symfony/Component/Messenger/EventListener/SendFailedMessageForRetryListener.php +++ b/src/Symfony/Component/Messenger/EventListener/SendFailedMessageForRetryListener.php @@ -12,7 +12,6 @@ use Psr\Container\ContainerInterface; use Psr\Log\LoggerInterface; -use Psr\Log\LogLevel; use Symfony\Component\EventDispatcher\EventSubscriberInterface; use Symfony\Component\Messenger\Envelope; use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent; @@ -71,18 +70,7 @@ public function onMessageFailed(WorkerMessageFailedEvent $event) $delay = $retryStrategy->getWaitingTime($envelope, $throwable); if (null !== $this->logger) { - $logLevel = LogLevel::ERROR; - if ($throwable instanceof RecoverableExceptionInterface) { - $logLevel = LogLevel::WARNING; - } elseif ($throwable instanceof HandlerFailedException) { - foreach ($throwable->getNestedExceptions() as $nestedException) { - if ($nestedException instanceof RecoverableExceptionInterface) { - $logLevel = LogLevel::WARNING; - break; - } - } - } - $this->logger->log($logLevel, 'Error thrown while handling message {class}. Sending for retry #{retryCount} using {delay} ms delay. Error: "{error}"', $context + ['retryCount' => $retryCount, 'delay' => $delay, 'error' => $throwable->getMessage(), 'exception' => $throwable]); + $this->logger->warning('Error thrown while handling message {class}. Sending for retry #{retryCount} using {delay} ms delay. Error: "{error}"', $context + ['retryCount' => $retryCount, 'delay' => $delay, 'error' => $throwable->getMessage(), 'exception' => $throwable]); } // add the delay and retry stamp info