@@ -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 | } |