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

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