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

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 Shopware\Core\Framework\Plugin\Event\PluginPostUpdateEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener;
  13. /**
  14.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  15.  */
  16. class PluginLifecycleSubscriber implements EventSubscriberInterface
  17. {
  18.     private TaskRegistry $registry;
  20.     private CacheItemPoolInterface $restartSignalCachePool;
  22.     /**
  23.      * @internal
  24.      */
  25.     public function __construct(TaskRegistry $registry, CacheItemPoolInterface $restartSignalCachePool)
  26.     {
  27.         $this->registry = $registry;
  28.         $this->restartSignalCachePool = $restartSignalCachePool;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             PluginPostActivateEvent::class => 'afterPluginStateChange',
  35.             PluginPostDeactivateEvent::class => 'afterPluginStateChange',
  36.             PluginPostUpdateEvent::class => 'afterPluginStateChange',
  37.         ];
  38.     }
  40.     public function afterPluginStateChange(): void
  41.     {
  42.         $this->registry->registerTasks();
  44.         // signal worker restart
  45.         $cacheItem = $this->restartSignalCachePool->getItem(StopWorkerOnRestartSignalListener::RESTART_REQUESTED_TIMESTAMP_KEY);
  46.         $cacheItem->set(microtime(true));
  47.         $this->restartSignalCachePool->save($cacheItem);
  48.     }
  49. }