WatchableDispatchesJobs::dispatch()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 8
Code Lines 4

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 8
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 4
nc 1
nop 2
1
<?php namespace Maqe\Qwatcher\Traits;
2
3
use DB;
4
use Illuminate\Contracts\Bus\Dispatcher;
5
use Maqe\Qwatcher\Facades\Qwatch;
6
use Maqe\Qwatcher\Tracks\QueueTracks;
7
8
trait WatchableDispatchesJobs
9
{
10
    /**
11
     * Dispatch a job to its appropriate handler.
12
     *
13
     * @param  mixed  $job
14
     * @param  array  $meta
15
     * @return mixed
16
     */
17
    public function dispatch($job, array $meta = [])
18
    {
19
        $id = app(Dispatcher::class)->dispatch($job);
20
21
        Qwatch::tracks(new QueueTracks($id, $job, $meta));
22
23
        return $id;
24
    }
25
26
    /**
27
     * Dispatch a command to its appropriate handler in the current process.
28
     *
29
     * @param  mixed  $job
30
     * @return mixed
31
     */
32
    public function dispatchNow($job)
33
    {
34
        Qwatch::queued($job);
35
36
        return app(Dispatcher::class)->dispatchNow($job);
37
    }
38
}
39