Skip to content

Commit 8db64eb

Browse files
committed
style: cs-fix
1 parent 8493321 commit 8db64eb

5 files changed

Lines changed: 24 additions & 22 deletions

File tree

src/Commands/Work.php

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111

1212
namespace BlitzPHP\Queue\Commands;
1313

14-
use BlitzPHP\Cache\Handlers\BaseHandler;
1514
use BlitzPHP\Cli\Console\Command;
1615
use BlitzPHP\Cli\Console\Console;
1716
use BlitzPHP\Contracts\Cache\CacheInterface;
@@ -119,7 +118,7 @@ public function __construct(protected ContainerInterface $container, protected C
119118
$this->worker = service('worker');
120119
$this->cache = $container->get(CacheInterface::class);
121120
$this->events = $container->get(EventManagerInterface::class);
122-
}
121+
}
123122

124123
/**
125124
* Exécute la commande console.

src/Config/queue.php

Lines changed: 18 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,9 @@
1010
*/
1111

1212
use BlitzPHP\Queue\Drivers\DatabaseDriver;
13+
use BlitzPHP\Queue\Drivers\FailoverDriver;
14+
use BlitzPHP\Queue\Drivers\NullDriver;
15+
use BlitzPHP\Queue\Drivers\SyncDriver;
1316

1417
/**
1518
* Configuration du composant de files d'attente (queue).
@@ -70,22 +73,22 @@
7073
*/
7174
'table' => env('queue.database.table', 'queue_jobs'),
7275

73-
/**
74-
* Nom de la file logique par défaut pour cette connexion
75-
* (colonne `queue` en base). Utilisé si `queue:work` n'en précise pas.
76-
*/
76+
/**
77+
* Nom de la file logique par défaut pour cette connexion
78+
* (colonne `queue` en base). Utilisé si `queue:work` n'en précise pas.
79+
*/
7780
'queue' => env('queue.defaultQueue', 'default'),
7881

79-
/**
80-
* Délai en secondes au-delà duquel un job réservé est considéré
81-
* comme expiré et peut être repris par un autre worker.
82-
*/
82+
/**
83+
* Délai en secondes au-delà duquel un job réservé est considéré
84+
* comme expiré et peut être repris par un autre worker.
85+
*/
8386
'retry_after' => (int) env('queue.retryAfter', 90),
8487

85-
/**
86-
* Si `true`, n'envoie le job qu'après le commit des transactions
87-
* de base de données en cours.
88-
*/
88+
/**
89+
* Si `true`, n'envoie le job qu'après le commit des transactions
90+
* de base de données en cours.
91+
*/
8992
'after_commit' => false,
9093
],
9194

@@ -218,9 +221,9 @@
218221
// 'redis' => \BlitzPHP\Queue\Drivers\RedisDriver::class,
219222
// 'predis' => \BlitzPHP\Queue\Drivers\PredisDriver::class,
220223
// 'rabbitmq' => \BlitzPHP\Queue\Drivers\RabbitMQDriver::class,
221-
'sync' => \BlitzPHP\Queue\Drivers\SyncDriver::class,
222-
'null' => \BlitzPHP\Queue\Drivers\NullDriver::class,
223-
'failover' => \BlitzPHP\Queue\Drivers\FailoverDriver::class,
224+
'sync' => SyncDriver::class,
225+
'null' => NullDriver::class,
226+
'failover' => FailoverDriver::class,
224227
],
225228

226229
/**

src/Events/QueueEventManager.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@ class QueueEventManager
2727
/**
2828
* Noms d'événements des opérations de file.
2929
*/
30+
public const JOB_POPPING = 'queue.job.popping';
3031

31-
public const JOB_POPPING = 'queue.job.popping';
3232
public const JOB_POPPED = 'queue.job.popped';
3333
public const JOB_PUSHED = 'queue.job.pushed';
3434
public const JOB_PUSH_FAILED = 'queue.job.push.failed';

src/Job.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -70,12 +70,12 @@ public function queue(): string
7070
return $this->queue;
7171
}
7272

73-
/**
73+
/**
7474
* Ajoute le job sur la queue dans la file d'attente
7575
*/
7676
public function push(): mixed
7777
{
78-
return $this->pushOn($this->queue);
78+
return $this->pushOn($this->queue);
7979
}
8080

8181
/**
@@ -91,7 +91,7 @@ public function pushOn(string $queue): mixed
9191
*/
9292
public function pushLater(DateInterval|DateTimeInterface|int $delay): mixed
9393
{
94-
return $this->pushLaterOn($this->queue, $delay);
94+
return $this->pushLaterOn($this->queue, $delay);
9595
}
9696

9797
/**

src/Traits/Dispatchable.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,6 @@ public static function dispatchSync(mixed ...$parameters): void
6767
{
6868
$job = new static(...$parameters);
6969

70-
Services::container()->call([$job, 'handle']);
70+
Services::container()->call([$job, 'handle']);
7171
}
7272
}

0 commit comments

Comments
 (0)