onMessage = function ($connection, $data) { $connection->send('received: ' . $data); }; Worker::$command = 'start'; Worker::runAll();