onQueue($queue); $this->params = $params; } /** * Execute the job. * * @return void */ public function handle() { $mailLog = MailService::sendEmail($this->params); if($mailLog['error']){ $this->release(); //发送失败将触发重试 } } }