@@ -36,15 +36,15 @@ discard block |
||
| 36 | 36 | |
| 37 | 37 | $this->app->singleton(StoreResolver::class); |
| 38 | 38 | |
| 39 | - $this->app->singleton('heavy-jobs-store', function (Application $app) { |
|
| 39 | + $this->app->singleton('heavy-jobs-store', function(Application $app) { |
|
| 40 | 40 | return $app->make(PayloadStoreManager::class); |
| 41 | 41 | }); |
| 42 | 42 | |
| 43 | - $this->app->extend(QueueFactory::class, function (QueueManager $manager, Application $app) { |
|
| 43 | + $this->app->extend(QueueFactory::class, function(QueueManager $manager, Application $app) { |
|
| 44 | 44 | return new QueueManagerDecorator($manager, $app); |
| 45 | 45 | }); |
| 46 | 46 | |
| 47 | - $this->app->extend(FailedJobProviderInterface::class, function (FailedJobProviderInterface $provider) { |
|
| 47 | + $this->app->extend(FailedJobProviderInterface::class, function(FailedJobProviderInterface $provider) { |
|
| 48 | 48 | return new FailedJobProviderDecorator($provider); |
| 49 | 49 | }); |
| 50 | 50 | |
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | |
| 54 | 54 | private function registerPayloadCleaner(): void |
| 55 | 55 | { |
| 56 | - Queue::createPayloadUsing(function ($connection, $queue, $payload) { |
|
| 56 | + Queue::createPayloadUsing(function($connection, $queue, $payload) { |
|
| 57 | 57 | $job = Arr::get($payload, 'data.command'); |
| 58 | 58 | if ($job instanceof HeavyJob) { |
| 59 | 59 | return [ |
@@ -64,7 +64,7 @@ discard block |
||
| 64 | 64 | return []; |
| 65 | 65 | }); |
| 66 | 66 | |
| 67 | - $this->app['events']->listen(JobProcessed::class, function (JobProcessed $event): void { |
|
| 67 | + $this->app['events']->listen(JobProcessed::class, function(JobProcessed $event): void { |
|
| 68 | 68 | if ($heavyPayloadId = Arr::get($event->job->payload(), 'heavy-payload-id')) { |
| 69 | 69 | HeavyJobsStore::remove($heavyPayloadId); |
| 70 | 70 | } |