Lower log level in case of retry

jderusse · jderusse · commit cf2c6e818090 · 2021-10-14T10:17:12.000+02:00
diff --git 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
