vendor/crehler/default-product-data/src/Subscriber/ProductWriteSubscriber.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * @copyright 2020 Crehler Sp. z o. o. <https://crehler.com>
  4.  *
  5.  * @author    Jakub Medyński <jme@crehler.com>
  6.  * @support   Crehler <support@crehler.com>
  7.  * @created   09 gru 2020
  8.  *
  9.  * For the full copyright and license information, please view the LICENSE
  10.  * file that was distributed with this source code.
  11.  */
  13. namespace Crehler\DefaultProductData\Subscriber;
  16. use Crehler\DefaultProductData\Message\WriteProductMessage;
  17. use Enqueue\MessengerAdapter\EnvelopeItem\TransportConfiguration;
  18. use Shopware\Core\Content\Product\ProductEvents;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\Messenger\MessageBusInterface;
  23. class ProductWriteSubscriber implements EventSubscriberInterface
  24. {
  26.     private MessageBusInterface $messageBus;
  28.     public function __construct(MessageBusInterface $messageBus)
  29.     {
  30.         $this->messageBus = $messageBus;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'onProductWrite'
  37.         ];
  38.     }
  40.     public function onProductWrite(EntityWrittenEvent $event): void
  41.     {
  42.         $message = new WriteProductMessage();
  44.         $message->withContext($event->getContext())
  45.             ->setIds($event->getIds());
  47.         $this->messageBus->dispatch(
  48.             $message,
  49.             [new TransportConfiguration(['topic' => 'crehlerdefaultproductdata'])]
  50.         );
  51.     }
  52. }