v2 first commit
This commit is contained in:
40
app/Traits/Jobs.php
Normal file
40
app/Traits/Jobs.php
Normal file
@@ -0,0 +1,40 @@
|
||||
<?php
|
||||
|
||||
namespace App\Traits;
|
||||
|
||||
trait Jobs
|
||||
{
|
||||
/**
|
||||
* Dispatch a job to its appropriate handler.
|
||||
*
|
||||
* @param mixed $job
|
||||
* @return mixed
|
||||
*/
|
||||
public function dispatch($job)
|
||||
{
|
||||
$function = $this->getDispatchMethod();
|
||||
|
||||
return $function($job);
|
||||
}
|
||||
|
||||
/**
|
||||
* Dispatch a command to its appropriate handler in the current process.
|
||||
*
|
||||
* @param mixed $job
|
||||
* @param mixed $handler
|
||||
* @return mixed
|
||||
*/
|
||||
public function dispatchNow($job, $handler = null)
|
||||
{
|
||||
$result = dispatch_now($job, $handler);
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
public function getDispatchMethod()
|
||||
{
|
||||
$config = config('queue.default');
|
||||
|
||||
return ($config == 'sync') ? 'dispatch_now' : 'dispatch';
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user