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. }