vendor/shopware/core/Framework/MessageQueue/ScheduledTask/Subscriber/PluginLifecycleSubscriber.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. namespace Shopware\Core\Framework\MessageQueue\ScheduledTask\Subscriber;
  3. use Psr\Cache\CacheItemPoolInterface;
  4. use Shopware\Core\Framework\MessageQueue\ScheduledTask\Registry\TaskRegistry;
  5. use Shopware\Core\Framework\Plugin\Event\PluginPostActivateEvent;
  6. use Shopware\Core\Framework\Plugin\Event\PluginPostDeactivateEvent;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener;
  9. class PluginLifecycleSubscriber implements EventSubscriberInterface
  10. {
  11.     /**
  12.      * @var TaskRegistry
  13.      */
  14.     private $registry;
  15.     /**
  16.      * @var CacheItemPoolInterface
  17.      */
  18.     private $restartSignalCachePool;
  19.     /**
  20.      * @internal
  21.      */
  22.     public function __construct(TaskRegistry $registryCacheItemPoolInterface $restartSignalCachePool)
  23.     {
  24.         $this->registry $registry;
  25.         $this->restartSignalCachePool $restartSignalCachePool;
  26.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             PluginPostActivateEvent::class => 'afterPluginStateChange',
  31.             PluginPostDeactivateEvent::class => 'afterPluginStateChange',
  32.         ];
  33.     }
  34.     public function afterPluginStateChange(): void
  35.     {
  36.         $this->registry->registerTasks();
  37.         // signal worker restart
  38.         $cacheItem $this->restartSignalCachePool->getItem(StopWorkerOnRestartSignalListener::RESTART_REQUESTED_TIMESTAMP_KEY);
  39.         $cacheItem->set(microtime(true));
  40.         $this->restartSignalCachePool->save($cacheItem);
  41.     }
  42. }