@@ -73,55 +73,55 @@ |
||
| 73 | 73 | public function register(): void |
| 74 | 74 | { |
| 75 | 75 | $provider = $this->listenerProvider; |
| 76 | - $provider->addListener(function (BeforeEnqueue $task) { |
|
| 76 | + $provider->addListener(function(BeforeEnqueue $task) { |
|
| 77 | 77 | $this->logTask($task); |
| 78 | 78 | }); |
| 79 | - $provider->addListener(function (AfterEnqueue $task) { |
|
| 79 | + $provider->addListener(function(AfterEnqueue $task) { |
|
| 80 | 80 | $this->logTask($task); |
| 81 | 81 | }); |
| 82 | - $provider->addListener(function (BeforeJobPop $task) { |
|
| 82 | + $provider->addListener(function(BeforeJobPop $task) { |
|
| 83 | 83 | $this->logTask($task); |
| 84 | 84 | }); |
| 85 | - $provider->addListener(function (BeforeJobPush $task) { |
|
| 85 | + $provider->addListener(function(BeforeJobPush $task) { |
|
| 86 | 86 | $this->logTask($task); |
| 87 | 87 | }); |
| 88 | - $provider->addListener(function (BeforeSignalsRegister $task) { |
|
| 88 | + $provider->addListener(function(BeforeSignalsRegister $task) { |
|
| 89 | 89 | $this->logTask($task); |
| 90 | 90 | }); |
| 91 | - $provider->addListener(function (BeforeUserJobPerform $task) { |
|
| 91 | + $provider->addListener(function(BeforeUserJobPerform $task) { |
|
| 92 | 92 | $this->logTask($task); |
| 93 | 93 | }); |
| 94 | - $provider->addListener(function (AfterUserJobPerform $task) { |
|
| 94 | + $provider->addListener(function(AfterUserJobPerform $task) { |
|
| 95 | 95 | $this->logTask($task); |
| 96 | 96 | }); |
| 97 | - $provider->addListener(function (FailedUserJobPerform $task) { |
|
| 97 | + $provider->addListener(function(FailedUserJobPerform $task) { |
|
| 98 | 98 | $this->logTask($task); |
| 99 | 99 | }); |
| 100 | - $provider->addListener(function (ForkFailed $task) { |
|
| 100 | + $provider->addListener(function(ForkFailed $task) { |
|
| 101 | 101 | $this->logTask($task); |
| 102 | 102 | }); |
| 103 | - $provider->addListener(function (JobFailed $task) { |
|
| 103 | + $provider->addListener(function(JobFailed $task) { |
|
| 104 | 104 | $this->logTask($task); |
| 105 | 105 | }); |
| 106 | - $provider->addListener(function (ParentWaiting $task) { |
|
| 106 | + $provider->addListener(function(ParentWaiting $task) { |
|
| 107 | 107 | $this->logTask($task); |
| 108 | 108 | }); |
| 109 | - $provider->addListener(function (UnknownChildFailure $task) { |
|
| 109 | + $provider->addListener(function(UnknownChildFailure $task) { |
|
| 110 | 110 | $this->logTask($task); |
| 111 | 111 | }); |
| 112 | - $provider->addListener(function (WorkerDoneWorking $task) { |
|
| 112 | + $provider->addListener(function(WorkerDoneWorking $task) { |
|
| 113 | 113 | $this->logTask($task); |
| 114 | 114 | }); |
| 115 | - $provider->addListener(function (WorkerIdle $task) { |
|
| 115 | + $provider->addListener(function(WorkerIdle $task) { |
|
| 116 | 116 | $this->logTask($task); |
| 117 | 117 | }); |
| 118 | - $provider->addListener(function (WorkerRegistering $task) { |
|
| 118 | + $provider->addListener(function(WorkerRegistering $task) { |
|
| 119 | 119 | $this->logTask($task); |
| 120 | 120 | }); |
| 121 | - $provider->addListener(function (WorkerStartup $task) { |
|
| 121 | + $provider->addListener(function(WorkerStartup $task) { |
|
| 122 | 122 | $this->logTask($task); |
| 123 | 123 | }); |
| 124 | - $provider->addListener(function (WorkerUnregistering $task) { |
|
| 124 | + $provider->addListener(function(WorkerUnregistering $task) { |
|
| 125 | 125 | $this->logTask($task); |
| 126 | 126 | }); |
| 127 | 127 | } |