class Pusher
{
    public function onWorkerStart()
    {
       //$GLOBALS['con'];
      global  $con;
      $con = new AsyncTcpConnection('tcp://127.0.0.1:8282');

      $con->onConnect = function(AsyncTcpConnection $con) {
         $con->send('hello');
       };

       $con->onMessage = function(AsyncTcpConnection $con, $data) {
         echo $data;
         $con->send($data);
       };

       $con->connect();
    }
}