@@ -12,9 +12,9 @@ |
||
12 | 12 | namespace DNXLabs\LaravelQueueAwsBatch\Connectors; |
13 | 13 | |
14 | 14 | use Aws\Batch\BatchClient; |
15 | +use DNXLabs\LaravelQueueAwsBatch\Queues\BatchQueue; |
|
15 | 16 | use Illuminate\Queue\Connectors\DatabaseConnector; |
16 | 17 | use Illuminate\Support\Arr; |
17 | -use DNXLabs\LaravelQueueAwsBatch\Queues\BatchQueue; |
|
18 | 18 | |
19 | 19 | class BatchConnector extends DatabaseConnector |
20 | 20 | { |
@@ -11,6 +11,9 @@ discard block |
||
11 | 11 | |
12 | 12 | namespace DNXLabs\LaravelQueueAwsBatch\Console; |
13 | 13 | |
14 | +use DNXLabs\LaravelQueueAwsBatch\Exceptions\JobNotFoundException; |
|
15 | +use DNXLabs\LaravelQueueAwsBatch\Exceptions\UnsupportedException; |
|
16 | +use DNXLabs\LaravelQueueAwsBatch\Queues\BatchQueue; |
|
14 | 17 | use Illuminate\Container\Container; |
15 | 18 | use Illuminate\Contracts\Cache\Repository; |
16 | 19 | use Illuminate\Foundation\Exceptions\Handler; |
@@ -18,9 +21,6 @@ discard block |
||
18 | 21 | use Illuminate\Queue\QueueManager; |
19 | 22 | use Illuminate\Queue\Worker; |
20 | 23 | use Illuminate\Queue\WorkerOptions; |
21 | -use DNXLabs\LaravelQueueAwsBatch\Exceptions\JobNotFoundException; |
|
22 | -use DNXLabs\LaravelQueueAwsBatch\Exceptions\UnsupportedException; |
|
23 | -use DNXLabs\LaravelQueueAwsBatch\Queues\BatchQueue; |
|
24 | 24 | use Symfony\Component\Debug\Exception\FatalThrowableError; |
25 | 25 | |
26 | 26 | class QueueWorkBatchCommand extends WorkCommand |
@@ -115,6 +115,9 @@ |
||
115 | 115 | return $this->marshalJob($job->queue, $job); |
116 | 116 | } |
117 | 117 | |
118 | + /** |
|
119 | + * @param DatabaseJobRecord $job |
|
120 | + */ |
|
118 | 121 | protected function marshalJob($queue, $job) |
119 | 122 | { |
120 | 123 | $job = $this->markJobAsReserved($job); |
@@ -12,12 +12,12 @@ |
||
12 | 12 | namespace DNXLabs\LaravelQueueAwsBatch\Queues; |
13 | 13 | |
14 | 14 | use Aws\Batch\BatchClient; |
15 | -use Illuminate\Database\Connection; |
|
16 | -use Illuminate\Queue\DatabaseQueue; |
|
17 | -use Illuminate\Queue\Jobs\DatabaseJobRecord; |
|
18 | 15 | use DNXLabs\LaravelQueueAwsBatch\Exceptions\JobNotFoundException; |
19 | 16 | use DNXLabs\LaravelQueueAwsBatch\Exceptions\UnsupportedException; |
20 | 17 | use DNXLabs\LaravelQueueAwsBatch\Jobs\BatchJob; |
18 | +use Illuminate\Database\Connection; |
|
19 | +use Illuminate\Queue\DatabaseQueue; |
|
20 | +use Illuminate\Queue\Jobs\DatabaseJobRecord; |
|
21 | 21 | |
22 | 22 | class BatchQueue extends DatabaseQueue |
23 | 23 | { |