diff --git a/src/Jobs/FailResolving/PushDelayedResolver.php b/src/Jobs/FailResolving/PushDelayedResolver.php index 92de66c..79df2b4 100644 --- a/src/Jobs/FailResolving/PushDelayedResolver.php +++ b/src/Jobs/FailResolving/PushDelayedResolver.php @@ -26,10 +26,10 @@ public function __construct(QueueManagerInterface $queueManager, LoggerInterface public function resolve(JobInterface $job, Throwable $exception): void { - $job->incrementAttempts(); - $pushDelayInMilliseconds = $this->getDelayInMilliseconds($job, $exception); + $job->incrementAttempts(); + $this->queueManager->pushDelayedWithMilliseconds($job, $pushDelayInMilliseconds); $this->logger->warning(