@@ -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 |