@@ -225,7 +225,7 @@ class QappUserService
UserTaskService::addUserTaskQueue($user->id, BaseTask::register, UserTaskService::add_trigger);
- new NewUserPushMsgDelay($user->id);
+ $job = new NewUserPushMsgDelay($user->id);
dispatch($job->onConnection('rabbitmq')->onQueue('new_user_push_msg'));
// 同步数据