1 回答
TA贡献1876条经验 获得超6个赞
您可以使用onConnection方法即时设置驱动程序。
$schedule->job((new Heartbeat)->onConnection('sync'))->everyFiveMinutes();
另一种选择可能是在调用该job方法时,设置connection.
/**
* Add a new job callback event to the schedule.
*
* @param object|string $job
* @param string|null $queue
* @param string|null $connection
* @return \Illuminate\Console\Scheduling\CallbackEvent
*/
public function job($job, $queue = null, $connection = null)
{
return $this->call(function () use ($job, $queue, $connection) {
$job = is_string($job) ? Container::getInstance()->make($job) : $job;
if ($job instanceof ShouldQueue) {
$this->dispatchToQueue($job, $queue ?? $job->queue, $connection ?? $job->connection);
} else {
$this->dispatchNow($job);
}
})->name(is_string($job) ? $job : get_class($job));
}
- 1 回答
- 0 关注
- 120 浏览
添加回答
举报