@@ -5,7 +5,6 @@ |
||
5 | 5 | use Symfony\Component\Console\Input\InputOption; |
6 | 6 | use Symfony\Component\Console\Input\InputInterface; |
7 | 7 | use Symfony\Component\Console\Output\OutputInterface; |
8 | - |
|
9 | 8 | use Workana\AsyncJobs\Util\Ping; |
10 | 9 | use Workana\AsyncJobs\AsyncAction; |
11 | 10 | use Workana\AsyncJobs\JobManager; |
@@ -40,7 +40,7 @@ |
||
40 | 40 | public function configure() |
41 | 41 | { |
42 | 42 | $this->setDescription('Send a ping') |
43 | - ->addOption( |
|
43 | + ->addOption( |
|
44 | 44 | 'queues', |
45 | 45 | null, |
46 | 46 | InputOption::VALUE_REQUIRED, |
@@ -38,7 +38,6 @@ |
||
38 | 38 | protected $info; |
39 | 39 | |
40 | 40 | /** |
41 | - * @param Job $job |
|
42 | 41 | * @param Exception|Throwable $error |
43 | 42 | */ |
44 | 43 | public function __construct(Envelope $envelope, $error, Worker $worker, ExecutionInfo $info) |
@@ -74,7 +74,7 @@ |
||
74 | 74 | /** |
75 | 75 | * Children exceptions |
76 | 76 | * |
77 | - * @return AggregateChildEventException |
|
77 | + * @return ChildEventException[] |
|
78 | 78 | */ |
79 | 79 | public function getChildren() |
80 | 80 | { |
@@ -18,7 +18,6 @@ discard block |
||
18 | 18 | /** |
19 | 19 | * Normalizes an object into a set of arrays/scalars. |
20 | 20 | * |
21 | - * @param object $object object to normalize |
|
22 | 21 | * @param string $format format the normalization result will be encoded as |
23 | 22 | * @param array $context Context options for the normalizer |
24 | 23 | * |
@@ -46,7 +45,6 @@ discard block |
||
46 | 45 | * Denormalizes data back into an object of the given class. |
47 | 46 | * |
48 | 47 | * @param mixed $data data to restore |
49 | - * @param string $class the expected class to instantiate |
|
50 | 48 | * @param string $format format the given data was extracted from |
51 | 49 | * @param array $context options available to the denormalizer |
52 | 50 | * |
@@ -3,7 +3,6 @@ |
||
3 | 3 | |
4 | 4 | use Throwable; |
5 | 5 | use Exception; |
6 | - |
|
7 | 6 | use Bernard\Envelope; |
8 | 7 | use Bernard\Queue; |
9 | 8 | use Bernard\Router; |
@@ -10,7 +10,9 @@ |
||
10 | 10 | { |
11 | 11 | public function compare($priority1, $priority2) |
12 | 12 | { |
13 | - if ($priority1 === $priority2) return 0; |
|
13 | + if ($priority1 === $priority2) { |
|
14 | + return 0; |
|
15 | + } |
|
14 | 16 | return ($priority1 < $priority2) ? -1 : 1; |
15 | 17 | } |
16 | 18 | } |
17 | 19 | \ No newline at end of file |
@@ -133,6 +133,6 @@ |
||
133 | 133 | |
134 | 134 | public function withPreferredQueueName($preferredQueueName) |
135 | 135 | { |
136 | - $this->preferredQueueName = $preferredQueueName ?(string) $preferredQueueName : null; |
|
136 | + $this->preferredQueueName = $preferredQueueName ? (string) $preferredQueueName : null; |
|
137 | 137 | } |
138 | 138 | } |
139 | 139 | \ No newline at end of file |
@@ -39,7 +39,7 @@ |
||
39 | 39 | public function configure() |
40 | 40 | { |
41 | 41 | $this->setDescription('Consume queues') |
42 | - ->addOption( |
|
42 | + ->addOption( |
|
43 | 43 | 'queues', |
44 | 44 | null, |
45 | 45 | InputOption::VALUE_REQUIRED, |
@@ -13,7 +13,9 @@ |
||
13 | 13 | */ |
14 | 14 | public function compare($priority1, $priority2) |
15 | 15 | { |
16 | - if ($priority1 === $priority2) return 0; |
|
16 | + if ($priority1 === $priority2) { |
|
17 | + return 0; |
|
18 | + } |
|
17 | 19 | return $priority1 < $priority2 ? -1 : 1; |
18 | 20 | } |
19 | 21 | } |
20 | 22 | \ No newline at end of file |