@@ -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, |
@@ -2,12 +2,12 @@ |
||
| 2 | 2 | namespace Workana\AsyncJobs\Console; |
| 3 | 3 | |
| 4 | 4 | use Symfony\Component\Console\Command\Command; |
| 5 | -use Symfony\Component\Console\Input\InputOption; |
|
| 6 | 5 | use Symfony\Component\Console\Input\InputInterface; |
| 6 | +use Symfony\Component\Console\Input\InputOption; |
|
| 7 | 7 | use Symfony\Component\Console\Output\OutputInterface; |
| 8 | -use Workana\AsyncJobs\Util\Ping; |
|
| 9 | 8 | use Workana\AsyncJobs\AsyncAction; |
| 10 | 9 | use Workana\AsyncJobs\JobManager; |
| 10 | +use Workana\AsyncJobs\Util\Ping; |
|
| 11 | 11 | |
| 12 | 12 | /** |
| 13 | 13 | * Produces a ping |
@@ -2,9 +2,9 @@ |
||
| 2 | 2 | namespace Workana\AsyncJobs\EventDispatching; |
| 3 | 3 | |
| 4 | 4 | use Exception; |
| 5 | -use Throwable; |
|
| 6 | -use Symfony\Component\EventDispatcher\EventDispatcher; |
|
| 7 | 5 | use Symfony\Component\EventDispatcher\Event; |
| 6 | +use Symfony\Component\EventDispatcher\EventDispatcher; |
|
| 7 | +use Throwable; |
|
| 8 | 8 | |
| 9 | 9 | /** |
| 10 | 10 | * Failover event dispatcher |
@@ -2,13 +2,13 @@ |
||
| 2 | 2 | namespace Workana\AsyncJobs; |
| 3 | 3 | |
| 4 | 4 | use Bernard\Driver; |
| 5 | -use Bernard\Serializer; |
|
| 5 | +use Bernard\Normalizer\EnvelopeNormalizer; |
|
| 6 | 6 | use Bernard\QueueFactory\PersistentFactory; |
| 7 | +use Bernard\Serializer; |
|
| 7 | 8 | use Interop\Container\ContainerInterface; |
| 8 | -use Symfony\Component\EventDispatcher\EventDispatcher; |
|
| 9 | 9 | use Normalt\Normalizer\AggregateNormalizer; |
| 10 | +use Symfony\Component\EventDispatcher\EventDispatcher; |
|
| 10 | 11 | use Workana\AsyncJobs\Dispatcher\AsyncJobDispatcher; |
| 11 | -use Bernard\Normalizer\EnvelopeNormalizer; |
|
| 12 | 12 | use Workana\AsyncJobs\Doctrine\QueueableEntityNormalizer; |
| 13 | 13 | use Workana\AsyncJobs\Normalizer\AsyncActionNormalizer; |
| 14 | 14 | use Workana\AsyncJobs\Normalizer\ParameterNormalizer; |
@@ -2,8 +2,8 @@ |
||
| 2 | 2 | namespace Workana\AsyncJobs\Normalizer; |
| 3 | 3 | |
| 4 | 4 | use Bernard\Normalizer\AbstractAggregateNormalizerAware; |
| 5 | -use Symfony\Component\Serializer\Normalizer\NormalizerInterface; |
|
| 6 | 5 | use Symfony\Component\Serializer\Normalizer\DenormalizerInterface; |
| 6 | +use Symfony\Component\Serializer\Normalizer\NormalizerInterface; |
|
| 7 | 7 | |
| 8 | 8 | class ScalarNormalizer extends AbstractAggregateNormalizerAware implements NormalizerInterface, DenormalizerInterface |
| 9 | 9 | { |
@@ -1,20 +1,20 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | namespace Workana\AsyncJobs; |
| 3 | 3 | |
| 4 | -use Throwable; |
|
| 5 | -use Exception; |
|
| 6 | 4 | use Bernard\Envelope; |
| 7 | 5 | use Bernard\Queue; |
| 8 | 6 | use Bernard\Router; |
| 7 | +use Exception; |
|
| 9 | 8 | use Symfony\Component\EventDispatcher\EventDispatcherInterface; |
| 10 | -use Workana\AsyncJobs\Event\SuccessfulExecutionEvent; |
|
| 11 | -use Workana\AsyncJobs\Process\ProcessManager; |
|
| 9 | +use Throwable; |
|
| 12 | 10 | use Workana\AsyncJobs\Event\AfterExecutionEvent; |
| 13 | 11 | use Workana\AsyncJobs\Event\BeforeExecutionEvent; |
| 14 | 12 | use Workana\AsyncJobs\Event\RejectedExecutionEvent; |
| 13 | +use Workana\AsyncJobs\Event\SuccessfulExecutionEvent; |
|
| 15 | 14 | use Workana\AsyncJobs\Event\WorkerShutdownEvent; |
| 16 | -use Workana\AsyncJobs\Util\Sleeper; |
|
| 15 | +use Workana\AsyncJobs\Process\ProcessManager; |
|
| 17 | 16 | use Workana\AsyncJobs\Retry\RetryStrategy; |
| 17 | +use Workana\AsyncJobs\Util\Sleeper; |
|
| 18 | 18 | |
| 19 | 19 | /** |
| 20 | 20 | * Worker class |