it works fine in examples but can not subscribe the 'test' topic in laravel command

[jin-null]

`public function handle()
{
global $argv;
$action = $this->argument('action');
if (!in_array($action, ['start', 'stop'])) {
$this->error('Error Arguments');
exit;
}
$argv[0] = 'workerman:httpserver';
$argv[1] = $action;
$argv[2] = $this->option('daemonize') ? '-d' : '';
$worker = new Worker();
$worker->onWorkerStart = function () {
// $mqtt = new Client('mqtt://192.168.0.247:1883');
$mqtt = new \Workerman\Mqtt\Client('mqtt://192.168.0.247:1883');
Log::info(1);
$mqtt->onConnect = function ($mqtt) {
$mqtt->subscribe('test');
$this->info(2);
};
$mqtt->onMessage = function ($topic, $content) {
var_dump($topic, $content);
$this->info($content);
};
};
Worker::runAll();

}`