@@ -34,21 +34,21 @@ discard block |
||
| 34 | 34 | |
| 35 | 35 | $registeredWorkers = app()->get('worker');
|
| 36 | 36 | |
| 37 | - if(isset($registeredWorkers[$worker])){
|
|
| 37 | + if (isset($registeredWorkers[$worker])) {
|
|
| 38 | 38 | |
| 39 | - if(!is_callable($registeredWorkers[$worker]) && Utils::isNamespaceExists($registeredWorkers[$worker])) {
|
|
| 40 | - $resolve = app()->resolve($registeredWorkers[$worker],['data'=>(array)$this->argument['data']]); |
|
| 39 | + if (!is_callable($registeredWorkers[$worker]) && Utils::isNamespaceExists($registeredWorkers[$worker])) {
|
|
| 40 | + $resolve = app()->resolve($registeredWorkers[$worker], ['data'=>(array)$this->argument['data']]); |
|
| 41 | 41 | } |
| 42 | 42 | |
| 43 | - while(true){
|
|
| 43 | + while (true) {
|
|
| 44 | 44 | |
| 45 | - if(isset($resolve)){
|
|
| 45 | + if (isset($resolve)) {
|
|
| 46 | 46 | $result = $resolve->handle(); |
| 47 | 47 | echo $this->classical($worker.' worker called : '.$result); |
| 48 | 48 | sleep($resolve->getSleep()); |
| 49 | 49 | } |
| 50 | 50 | |
| 51 | - if(is_callable($registeredWorkers[$worker])){
|
|
| 51 | + if (is_callable($registeredWorkers[$worker])) {
|
|
| 52 | 52 | echo $this->classical($registeredWorkers[$worker]((isset($this->argument['data']) && is_string($this->argument['data'])) ? $this->argument['data'] : null)); |
| 53 | 53 | sleep((isset($this->argument['sleep']) && is_numeric($this->argument['sleep'])) ? $this->argument['sleep'] : 0); |
| 54 | 54 | } |
@@ -65,7 +65,7 @@ discard block |
||
| 65 | 65 | */ |
| 66 | 66 | public function create() |
| 67 | 67 | {
|
| 68 | - if(!file_exists(app()->path()->workers())){
|
|
| 68 | + if (!file_exists(app()->path()->workers())) {
|
|
| 69 | 69 | $this->directory['worker'] = app()->path()->workers(); |
| 70 | 70 | $this->file->makeDirectory($this); |
| 71 | 71 | } |
@@ -74,7 +74,7 @@ discard block |
||
| 74 | 74 | $this->argument['workerClass'] = ucfirst($this->argument['worker']).''; |
| 75 | 75 | $this->argument['projectName'] = strtolower($this->projectName()); |
| 76 | 76 | |
| 77 | - $this->touch['worker/worker']= app()->path()->workers().'/'.$this->argument['worker'].'.php'; |
|
| 77 | + $this->touch['worker/worker'] = app()->path()->workers().'/'.$this->argument['worker'].'.php'; |
|
| 78 | 78 | |
| 79 | 79 | |
| 80 | 80 | $this->file->touch($this); |