vendor/symfony/messenger/Transport/Sync/SyncTransport.php line 63

Open in your IDE?
  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\Transport\Sync;
  14. use Symfony\Component\Messenger\Envelope;
  15. use Symfony\Component\Messenger\Exception\InvalidArgumentException;
  16. use Symfony\Component\Messenger\MessageBusInterface;
  17. use Symfony\Component\Messenger\Stamp\ReceivedStamp;
  18. use Symfony\Component\Messenger\Stamp\SentStamp;
  19. use Symfony\Component\Messenger\Transport\TransportInterface;
  21. /**
  22.  * Transport that immediately marks messages as received and dispatches for handling.
  23.  *
  24.  * @author Ryan Weaver <ryan@symfonycasts.com>
  25.  */
  26. class SyncTransport implements TransportInterface
  27. {
  28.     private $messageBus;
  30.     public function __construct(MessageBusInterface $messageBus)
  31.     {
  32.         $this->messageBus = $messageBus;
  33.     }
  35.     public function get(): iterable
  36.     {
  37.         throw new InvalidArgumentException('You cannot receive messages from the Messenger SyncTransport.');
  38.     }
  40.     public function stop(): void
  41.     {
  42.         throw new InvalidArgumentException('You cannot call stop() on the Messenger SyncTransport.');
  43.     }
  45.     public function ack(Envelope $envelope): void
  46.     {
  47.         throw new InvalidArgumentException('You cannot call ack() on the Messenger SyncTransport.');
  48.     }
  50.     public function reject(Envelope $envelope): void
  51.     {
  52.         throw new InvalidArgumentException('You cannot call reject() on the Messenger SyncTransport.');
  53.     }
  55.     public function send(Envelope $envelope): Envelope
  56.     {
  57.         /** @var SentStamp|null $sentStamp */
  58.         $sentStamp = $envelope->last(SentStamp::class);
  59.         $alias = null === $sentStamp ? 'sync' : ($sentStamp->getSenderAlias() ?: $sentStamp->getSenderClass());
  61.         $envelope = $envelope->with(new ReceivedStamp($alias));
  63.         return $this->messageBus->dispatch($envelope);
  64.     }
  65. }