|
2 | 2 |
|
3 | 3 | namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors;
|
4 | 4 |
|
5 |
| -use Illuminate\Support\Arr; |
6 |
| -use Interop\Amqp\AmqpContext; |
7 |
| -use InvalidArgumentException; |
8 |
| -use Illuminate\Contracts\Queue\Queue; |
9 |
| -use Illuminate\Queue\Events\JobFailed; |
10 |
| -use Interop\Amqp\AmqpConnectionFactory; |
| 5 | +use Enqueue\AmqpLib\AmqpConnectionFactory as EnqueueAmqpConnectionFactory; |
11 | 6 | use Enqueue\AmqpTools\DelayStrategyAware;
|
12 |
| -use Illuminate\Contracts\Events\Dispatcher; |
13 |
| -use Illuminate\Queue\Events\WorkerStopping; |
14 | 7 | use Enqueue\AmqpTools\RabbitMqDlxDelayStrategy;
|
| 8 | +use Illuminate\Contracts\Events\Dispatcher; |
| 9 | +use Illuminate\Contracts\Queue\Queue; |
15 | 10 | use Illuminate\Queue\Connectors\ConnectorInterface;
|
16 |
| -use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue; |
| 11 | +use Illuminate\Queue\Events\JobFailed; |
| 12 | +use Illuminate\Queue\Events\WorkerStopping; |
| 13 | +use Illuminate\Support\Arr; |
| 14 | +use Interop\Amqp\AmqpConnectionFactory; |
17 | 15 | use Interop\Amqp\AmqpConnectionFactory as InteropAmqpConnectionFactory;
|
18 |
| -use Enqueue\AmqpLib\AmqpConnectionFactory as EnqueueAmqpConnectionFactory; |
| 16 | +use Interop\Amqp\AmqpContext; |
| 17 | +use InvalidArgumentException; |
19 | 18 | use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\Listeners\RabbitMQFailedEvent;
|
20 | 19 | use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\RabbitMQQueue as HorizonRabbitMQQueue;
|
| 20 | +use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue; |
21 | 21 |
|
22 | 22 | class RabbitMQConnector implements ConnectorInterface
|
23 | 23 | {
|
|
0 commit comments