composer req ad3n/ratchet-bundle
Add new Ihsan\RatchetBundle\IhsanRatchetBundle()
in your AppKernel.php
<?php
namespace YourBundle\Message\Processor;
use Ihsan\RatchetBundle\Message\Message;
use Ihsan\RatchetBundle\Processor\MessageProcessorInterface;
use Ratchet\ConnectionInterface;
/**
* @author Muhamad Surya Iksanudin <surya.kejawen@gmail.com>
*/
class MyOwnMessageProcessor implements MessageProcessorInterface
{
/**
* @param ConnectionInterface $connection
* @param Message $message
*
* @return Message
*/
public function process(ConnectionInterface $connection, Message $message): Message
{
//$message is message send by the client
//Your Own Logic
return $message;//return original message or
//return new Message(json_encode(['message' => 'Hello', 'more_data_to_expose' => $data]));
}
}
You must add tag ihsan_ratchet.message_processor
to register your own message processor
YourBundle\Message\Processor\MyOwnMessageProcessor:
tags:
- { name: 'ihsan_ratchet.message_processor' }
WEB_SOCKET_PORT=7777
or
ihsan_ratchet:
web_socket_port: 7777
Run php bin/console ihsan:server:start