$wsWorker->onMessage = function($connection, $data) use ($db_conn, $session_id, $upgrade_name_array){
if (strlen($data) > 7) {
if (substr($data, 0, 7) == "UserId:") {
$data_exp = explode(":", $data);
return $UserId = $data_exp[1];
}
}
};