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

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\Log\Package;
  7. use Shopware\Core\Framework\MessageQueue\ScheduledTask\Registry\TaskRegistry;
  8. use Shopware\Core\Framework\Plugin\Event\PluginPostActivateEvent;
  9. use Shopware\Core\Framework\Plugin\Event\PluginPostDeactivateEvent;
  10. use Shopware\Core\Framework\Plugin\Event\PluginPostUpdateEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener;
  14. /**
  15. * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  16. */
  17. #[Package('system-settings')]
  18. class PluginLifecycleSubscriber implements EventSubscriberInterface
  19. {
  20. private TaskRegistry $registry;
  22. private CacheItemPoolInterface $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. PluginPostUpdateEvent::class => 'afterPluginStateChange',
  39. ];
  40. }
  42. public function afterPluginStateChange(): void
  43. {
  44. $this->registry->registerTasks();
  46. // signal worker restart
  47. $cacheItem = $this->restartSignalCachePool->getItem(StopWorkerOnRestartSignalListener::RESTART_REQUESTED_TIMESTAMP_KEY);
  48. $cacheItem->set(microtime(true));
  49. $this->restartSignalCachePool->save($cacheItem);
  50. }
  51. }