update log
This commit is contained in:
parent
07665a1e6f
commit
628a706771
|
|
@ -84,13 +84,13 @@ class QueueWorkCommand extends Command
|
||||||
exec('pkill -f "artisan queue:work"');
|
exec('pkill -f "artisan queue:work"');
|
||||||
}
|
}
|
||||||
|
|
||||||
$this->info("Starting {$workers} queue:work processes on connection '{$connection}' and queue '{$queue}' with options: '{$workerOptions}'...");
|
$this->line("Starting {$workers} queue:work processes on connection '{$connection}' and queue '{$queue}' with options: '{$workerOptions}'...");
|
||||||
|
|
||||||
$processes = [];
|
$processes = [];
|
||||||
$pipesList = [];
|
$pipesList = [];
|
||||||
|
|
||||||
for ($i = 1; $i <= $workers; $i++) {
|
for ($i = 1; $i <= $workers; $i++) {
|
||||||
$this->info("Launching worker {$i}...");
|
$this->line("Lastring: unching worker {$i}...");
|
||||||
$descriptors = [
|
$descriptors = [
|
||||||
1 => ['pipe', 'w'], // stdout
|
1 => ['pipe', 'w'], // stdout
|
||||||
2 => ['pipe', 'w'], // stderr
|
2 => ['pipe', 'w'], // stderr
|
||||||
|
|
@ -121,7 +121,7 @@ class QueueWorkCommand extends Command
|
||||||
if ($out !== '') {
|
if ($out !== '') {
|
||||||
foreach (explode("\n", trim($out)) as $line) {
|
foreach (explode("\n", trim($out)) as $line) {
|
||||||
if ($line !== '') {
|
if ($line !== '') {
|
||||||
$this->info("[Worker {$i}] " . $line);
|
$this->line("[Worker {$i}] " . $line);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue