vendor/symfony/doctrine-messenger/Transport/DoctrineSender.php line 46

  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\Messenger\Bridge\Doctrine\Transport;
  14. use Doctrine\DBAL\Exception as DBALException;
  15. use Symfony\Component\Messenger\Envelope;
  16. use Symfony\Component\Messenger\Exception\TransportException;
  17. use Symfony\Component\Messenger\Stamp\DelayStamp;
  18. use Symfony\Component\Messenger\Stamp\TransportMessageIdStamp;
  19. use Symfony\Component\Messenger\Transport\Sender\SenderInterface;
  20. use Symfony\Component\Messenger\Transport\Serialization\PhpSerializer;
  21. use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
  23. /**
  24.  * @author Vincent Touzet <vincent.touzet@gmail.com>
  25.  */
  26. class DoctrineSender implements SenderInterface
  27. {
  28.     private Connection $connection;
  29.     private SerializerInterface $serializer;
  31.     public function __construct(Connection $connection, SerializerInterface $serializer = null)
  32.     {
  33.         $this->connection = $connection;
  34.         $this->serializer = $serializer ?? new PhpSerializer();
  35.     }
  37.     public function send(Envelope $envelope): Envelope
  38.     {
  39.         $encodedMessage = $this->serializer->encode($envelope);
  41.         /** @var DelayStamp|null $delayStamp */
  42.         $delayStamp = $envelope->last(DelayStamp::class);
  43.         $delay = null !== $delayStamp ? $delayStamp->getDelay() : 0;
  45.         try {
  46.             $id = $this->connection->send($encodedMessage['body'], $encodedMessage['headers'] ?? [], $delay);
  47.         } catch (DBALException $exception) {
  48.             throw new TransportException($exception->getMessage(), 0, $exception);
  49.         }
  51.         return $envelope->with(new TransportMessageIdStamp($id));
  52.     }
  53. }