src/EventSubscriber/MessengerDeDuplicationSubscriber.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Messenger\DeDuplicationUniqueHashStamp;
  6. use Psr\Cache\CacheItemPoolInterface;
  7. use Psr\Cache\InvalidArgumentException;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\Messenger\Event\WorkerMessageHandledEvent;
  11. class MessengerDeDuplicationSubscriber implements EventSubscriberInterface
  12. {
  13.     private CacheItemPoolInterface $cacheItemPool;
  15.     public static function getSubscribedEvents(): array
  16.     {
  17.         return [
  18.             WorkerMessageHandledEvent::class => 'handleWorkerMessageHandled',
  19.         ];
  20.     }
  22.     public function __construct(CacheItemPoolInterface $cacheItemPool)
  23.     {
  24.         $this->cacheItemPool = $cacheItemPool;
  25.     }
  27.     /**
  28.      * @throws InvalidArgumentException
  29.      */
  30.     public function handleWorkerMessageHandled(WorkerMessageHandledEvent $event): void
  31.     {
  32.         /** @var DeDuplicationUniqueHashStamp $deDuplicationStamp */
  33.         $deDuplicationStamp = $event->getEnvelope()->last(DeDuplicationUniqueHashStamp::class);
  35.         if ($deDuplicationStamp instanceof DeDuplicationUniqueHashStamp && $uniqueKey = $deDuplicationStamp->getUniqueKey()) {
  36.             $this->cacheItemPool->deleteItem($uniqueKey);
  37.         }
  38.     }
  39. }