cfrutos / async-jobs

src/EventDispatching/AggregateRootEventException.php

Doc Comments +1 added lines, -1 removed lines

@@ -74,7 +74,7 @@
     /**
      * Children exceptions
      *
-     * @return AggregateChildEventException
+     * @return ChildEventException[]
      */
     public function getChildren()
     {

src/Normalizer/ScalarNormalizer.php

Doc Comments -2 removed lines

@@ -18,7 +18,6 @@ 
     /**
      * Normalizes an object into a set of arrays/scalars.
      *
-     * @param object $object  object to normalize
      * @param string $format  format the normalization result will be encoded as
      * @param array  $context Context options for the normalizer
      *
@@ -46,7 +45,6 @@ 
      * Denormalizes data back into an object of the given class.
      *
      * @param mixed  $data    data to restore
-     * @param string $class   the expected class to instantiate
      * @param string $format  format the given data was extracted from
      * @param array  $context options available to the denormalizer
      *

Unused Use Statements +1 added lines, -1 removed lines

@@ -2,8 +2,8 @@
 namespace Workana\AsyncJobs\Normalizer;
 
 use Bernard\Normalizer\AbstractAggregateNormalizerAware;
-use Symfony\Component\Serializer\Normalizer\NormalizerInterface;
 use Symfony\Component\Serializer\Normalizer\DenormalizerInterface;
+use Symfony\Component\Serializer\Normalizer\NormalizerInterface;
 
 class ScalarNormalizer extends AbstractAggregateNormalizerAware implements NormalizerInterface, DenormalizerInterface
 {

src/Job.php

Spacing +1 added lines, -1 removed lines

@@ -133,6 +133,6 @@
 
     public function withPreferredQueueName($preferredQueueName)
     {
-        $this->preferredQueueName = $preferredQueueName ?(string) $preferredQueueName : null;
+        $this->preferredQueueName = $preferredQueueName ? (string) $preferredQueueName : null;
     }
 }
\ No newline at end of file

src/Console/PingCommand.php

Indentation +1 added lines, -1 removed lines

@@ -40,7 +40,7 @@
     public function configure()
     {
         $this->setDescription('Send a ping')
-             ->addOption(
+                ->addOption(
                 'queues',
                 null,
                 InputOption::VALUE_REQUIRED,

Unused Use Statements +2 added lines, -2 removed lines

@@ -2,12 +2,12 @@
 namespace Workana\AsyncJobs\Console;
 
 use Symfony\Component\Console\Command\Command;
-use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
-use Workana\AsyncJobs\Util\Ping;
 use Workana\AsyncJobs\AsyncAction;
 use Workana\AsyncJobs\JobManager;
+use Workana\AsyncJobs\Util\Ping;
 
 /**
  * Produces a ping

src/EventDispatching/FailoverEventDispatcher.php

Unused Use Statements +2 added lines, -2 removed lines

@@ -2,9 +2,9 @@
 namespace Workana\AsyncJobs\EventDispatching;
 
 use Exception;
-use Throwable;
-use Symfony\Component\EventDispatcher\EventDispatcher;
 use Symfony\Component\EventDispatcher\Event;
+use Symfony\Component\EventDispatcher\EventDispatcher;
+use Throwable;
 
 /**
  * Failover event dispatcher

src/JobManager.php

Unused Use Statements +3 added lines, -3 removed lines

@@ -2,13 +2,13 @@
 namespace Workana\AsyncJobs;
 
 use Bernard\Driver;
-use Bernard\Serializer;
+use Bernard\Normalizer\EnvelopeNormalizer;
 use Bernard\QueueFactory\PersistentFactory;
+use Bernard\Serializer;
 use Interop\Container\ContainerInterface;
-use Symfony\Component\EventDispatcher\EventDispatcher;
 use Normalt\Normalizer\AggregateNormalizer;
+use Symfony\Component\EventDispatcher\EventDispatcher;
 use Workana\AsyncJobs\Dispatcher\AsyncJobDispatcher;
-use Bernard\Normalizer\EnvelopeNormalizer;
 use Workana\AsyncJobs\Doctrine\QueueableEntityNormalizer;
 use Workana\AsyncJobs\Normalizer\AsyncActionNormalizer;
 use Workana\AsyncJobs\Normalizer\ParameterNormalizer;

src/Worker.php

Unused Use Statements +5 added lines, -5 removed lines

@@ -1,20 +1,20 @@
 <?php
 namespace Workana\AsyncJobs;
 
-use Throwable;
-use Exception;
 use Bernard\Envelope;
 use Bernard\Queue;
 use Bernard\Router;
+use Exception;
 use Symfony\Component\EventDispatcher\EventDispatcherInterface;
-use Workana\AsyncJobs\Event\SuccessfulExecutionEvent;
-use Workana\AsyncJobs\Process\ProcessManager;
+use Throwable;
 use Workana\AsyncJobs\Event\AfterExecutionEvent;
 use Workana\AsyncJobs\Event\BeforeExecutionEvent;
 use Workana\AsyncJobs\Event\RejectedExecutionEvent;
+use Workana\AsyncJobs\Event\SuccessfulExecutionEvent;
 use Workana\AsyncJobs\Event\WorkerShutdownEvent;
-use Workana\AsyncJobs\Util\Sleeper;
+use Workana\AsyncJobs\Process\ProcessManager;
 use Workana\AsyncJobs\Retry\RetryStrategy;
+use Workana\AsyncJobs\Util\Sleeper;
 
 /**
  * Worker class