vendor/shopware/core/Framework/MessageQueue/ScheduledTask/RequeueDeadMessagesHandler.php line 44

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\MessageQueue\ScheduledTask;
  5. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  6. use Shopware\Core\Framework\Feature;
  7. use Shopware\Core\Framework\Log\Package;
  8. use Shopware\Core\Framework\MessageQueue\DeadMessage\RequeueDeadMessagesService;
  10. /**
  11.  * @deprecated tag:v6.5.0 - reason:remove-subscriber - Will be removed, as we use the default symfony retry mechanism
  12.  */
  13. #[Package('core')]
  14. class RequeueDeadMessagesHandler extends ScheduledTaskHandler
  15. {
  16.     /**
  17.      * @var RequeueDeadMessagesService
  18.      */
  19.     private $requeueService;
  21.     /**
  22.      * @internal
  23.      */
  24.     public function __construct(EntityRepositoryInterface $scheduledTaskRepository, RequeueDeadMessagesService $requeueService)
  25.     {
  26.         parent::__construct($scheduledTaskRepository);
  27.         $this->requeueService = $requeueService;
  28.     }
  30.     public static function getHandledMessages(): iterable
  31.     {
  32.         return [
  33.             RequeueDeadMessagesTask::class,
  34.         ];
  35.     }
  37.     public function run(): void
  38.     {
  39.         Feature::triggerDeprecationOrThrow(
  40.             'v6.5.0.0',
  41.             Feature::deprecatedClassMessage(__CLASS__, 'v6.5.0.0')
  42.         );
  44.         $this->requeueService->requeue();
  45.     }
  46. }