src/Infrastructure/EventSubscriber/MessengerSubscriber.php line 12

Open in your IDE?
  1. <?php
  3. namespace App\Infrastructure\EventSubscriber;
  5. use App\Messenger\TimestampableMessageInterface;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\Messenger\Event\SendMessageToTransportsEvent;
  8. use Symfony\Component\Messenger\Event\WorkerMessageReceivedEvent;
  10. class MessengerSubscriber implements EventSubscriberInterface
  11. {
  12.     public function onSendMessageToTransports(SendMessageToTransportsEvent $event): void
  13.     {
  14.         $envelope = $event->getEnvelope();
  15.         $message = $envelope->getMessage();
  17.         if ($message instanceof TimestampableMessageInterface) {
  18.             $message->setCreatedAt(new \DateTimeImmutable());
  19.         }
  20.     }
  22.     // this event is not triggered inside a sync transport
  23.     public function onWorkerMessageReceivedEvent(WorkerMessageReceivedEvent $event): void
  24.     {
  25.         $envelope = $event->getEnvelope();
  26.         $message = $envelope->getMessage();
  28.         if ($message instanceof TimestampableMessageInterface) {
  29.             $message->setHandlingAt(new \DateTimeImmutable());
  30.         }
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             SendMessageToTransportsEvent::class => 'onSendMessageToTransports',
  37.             WorkerMessageReceivedEvent::class   => 'onWorkerMessageReceivedEvent',
  38.         ];
  39.     }
  40. }