vendor/gos/web-socket-bundle/src/Pusher/Wamp/WampPusher.php line 11

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Gos\Bundle\WebSocketBundle\Pusher\Wamp;
  5. use Gos\Bundle\WebSocketBundle\Pusher\AbstractPusher;
  6. use Gos\Bundle\WebSocketBundle\Pusher\Message;
  7. use Gos\Bundle\WebSocketBundle\Router\WampRouter;
  8. use Gos\Component\WebSocketClient\Wamp\ClientInterface;
  9. use Symfony\Component\Serializer\SerializerInterface;
  11. trigger_deprecation('gos/web-socket-bundle', '3.1', 'The "%s" class is deprecated and will be removed in 4.0, use the symfony/messenger component instead.', WampPusher::class);
  13. /**
  14.  * @deprecated to be removed in 4.0, use the symfony/messenger component instead
  15.  */
  16. final class WampPusher extends AbstractPusher
  17. {
  18.     private ClientInterface $connection;
  19.     private WampConnectionFactoryInterface $connectionFactory;
  21.     public function __construct(
  22.         WampRouter $router,
  23.         SerializerInterface $serializer,
  24.         WampConnectionFactoryInterface $connectionFactory
  25.     ) {
  26.         parent::__construct($router, $serializer);
  28.         $this->connectionFactory = $connectionFactory;
  29.     }
  31.     protected function doPush(Message $message, array $context): void
  32.     {
  33.         if (false === $this->isConnected()) {
  34.             $this->connection = $this->connectionFactory->createConnection();
  35.             $this->connection->connect();
  36.             $this->setConnected();
  37.         }
  39.         $this->connection->publish($message->getTopic(), $this->serializer->serialize($message->getData(), 'json'));
  40.     }
  42.     public function close(): void
  43.     {
  44.         if (false === $this->isConnected()) {
  45.             return;
  46.         }
  48.         $this->connection->disconnect();
  49.     }
  50. }