@@ -50,7 +50,7 @@ discard block |
||
50 | 50 | public function pushRaw($payload, $queue = null, array $options = []) |
51 | 51 | { |
52 | 52 | //wiki https://wiki.swoole.com/wiki/page/134.html, task($data,$dst_worker_id), $dst_worker_id should be default -1 |
53 | - return $this->swoole->task($payload, (!is_numeric($queue) || $queue < 0) ? -1 : (int)$queue); |
|
53 | + return $this->swoole->task($payload, (!is_numeric($queue) || $queue < 0) ? -1 : (int) $queue); |
|
54 | 54 | } |
55 | 55 | |
56 | 56 | /** |
@@ -64,7 +64,7 @@ discard block |
||
64 | 64 | */ |
65 | 65 | public function later($delay, $job, $data = '', $queue = null) |
66 | 66 | { |
67 | - return Timer::after($this->secondsUntil($delay) * 1000, function () use ($job, $data, $queue) { |
|
67 | + return Timer::after($this->secondsUntil($delay) * 1000, function() use ($job, $data, $queue) { |
|
68 | 68 | return $this->push($job, $data, $queue); |
69 | 69 | }); |
70 | 70 | } |