|
@@ -83,7 +83,7 @@ class robot extends Command
|
|
|
// $con = new AsyncTcpConnection('ws://127.0.0.1:8282');
|
|
|
$con->onConnect = function($con) use($client) {
|
|
|
};
|
|
|
- $con->onMessage = function($con, $data) use($client, &$room_id, &$client_id, $user, $http_addr){
|
|
|
+ $con->onMessage = function($con, $data) use($client, &$room_id, &$client_id, $user, $http_addr, $worker){
|
|
|
//注册地址
|
|
|
Gateway::$registerAddress = '127.0.0.1:1238';
|
|
|
//格式化参数
|
|
@@ -167,7 +167,7 @@ class robot extends Command
|
|
|
Gateway::leaveGroup($client_id, $room_id);
|
|
|
Gateway::unbindUid($client_id, $user->user_id);
|
|
|
Gateway::closeClient($client_id);
|
|
|
- Worker::stopAll();
|
|
|
+ $worker->stopAll();
|
|
|
}
|
|
|
|
|
|
};
|