Merge pull request vyuldashev#228 from vyuldashev/analysis-zEjQ4O

Apply fixes from StyleCI

Author: vyuldashev

src/Horizon/RabbitMQQueue.php

@@ -2,12 +2,12 @@
 
 namespace VladimirYuldashev\LaravelQueueRabbitMQ\Horizon;
 
-use Illuminate\Contracts\Events\Dispatcher;
-use Laravel\Horizon\Events\JobDeleted;
-use Laravel\Horizon\Events\JobPushed;
-use Laravel\Horizon\Events\JobReserved;
 use Laravel\Horizon\JobId;
 use Laravel\Horizon\JobPayload;
+use Laravel\Horizon\Events\JobPushed;
+use Laravel\Horizon\Events\JobDeleted;
+use Laravel\Horizon\Events\JobReserved;
+use Illuminate\Contracts\Events\Dispatcher;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue as BaseRabbitMQQueue;
 

src/Queue/Connectors/RabbitMQConnector.php

@@ -2,20 +2,20 @@
 
 namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors;
 
-use Enqueue\AmqpLib\AmqpConnectionFactory as EnqueueAmqpConnectionFactory;
 use Illuminate\Support\Arr;
 use Interop\Amqp\AmqpContext;
+use InvalidArgumentException;
 use Illuminate\Contracts\Queue\Queue;
 use Interop\Amqp\AmqpConnectionFactory;
 use Enqueue\AmqpTools\DelayStrategyAware;
 use Illuminate\Contracts\Events\Dispatcher;
 use Illuminate\Queue\Events\WorkerStopping;
 use Enqueue\AmqpTools\RabbitMqDlxDelayStrategy;
 use Illuminate\Queue\Connectors\ConnectorInterface;
-use InvalidArgumentException;
-use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\RabbitMQQueue as HorizonRabbitMQQueue;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
 use Interop\Amqp\AmqpConnectionFactory as InteropAmqpConnectionFactory;
+use Enqueue\AmqpLib\AmqpConnectionFactory as EnqueueAmqpConnectionFactory;
+use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\RabbitMQQueue as HorizonRabbitMQQueue;
 
 class RabbitMQConnector implements ConnectorInterface
 {
@@ -41,7 +41,7 @@ public function connect(array $config): Queue
     {
         $factoryClass = Arr::get($config, 'factory_class', EnqueueAmqpConnectionFactory::class);
 
-        if (!class_exists($factoryClass) || !(new \ReflectionClass($factoryClass))->implementsInterface(InteropAmqpConnectionFactory::class)) {
+        if (! class_exists($factoryClass) || ! (new \ReflectionClass($factoryClass))->implementsInterface(InteropAmqpConnectionFactory::class)) {
             throw new \LogicException(sprintf('The factory_class option has to be valid class that implements "%s"', InteropAmqpConnectionFactory::class));
         }
 

src/Queue/Jobs/RabbitMQJob.php

@@ -11,8 +11,8 @@
 use Illuminate\Container\Container;
 use Illuminate\Database\DetectsDeadlocks;
 use Illuminate\Contracts\Queue\Job as JobContract;
-use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\RabbitMQQueue as HorizonRabbitMQQueue;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
+use VladimirYuldashev\LaravelQueueRabbitMQ\Horizon\RabbitMQQueue as HorizonRabbitMQQueue;
 
 class RabbitMQJob extends Job implements JobContract
 {
@@ -32,8 +32,7 @@ public function __construct(
         RabbitMQQueue $connection,
         AmqpConsumer $consumer,
         AmqpMessage $message
-    )
-    {
+    ) {
         $this->container = $container;
         $this->connection = $connection;
         $this->consumer = $consumer;
@@ -103,7 +102,7 @@ public function delete(): void
         $this->consumer->acknowledge($this->message);
 
         // required for Laravel Horizon
-        if($this->connection instanceof HorizonRabbitMQQueue) {
+        if ($this->connection instanceof HorizonRabbitMQQueue) {
             $this->connection->deleteReserved($this->queue, $this);
         }
     }

src/Queue/RabbitMQQueue.php

@@ -2,9 +2,9 @@
 
 namespace VladimirYuldashev\LaravelQueueRabbitMQ\Queue;
 
-use Illuminate\Support\Str;
 use RuntimeException;
 use Illuminate\Queue\Queue;
+use Illuminate\Support\Str;
 use Interop\Amqp\AmqpQueue;
 use Interop\Amqp\AmqpTopic;
 use Psr\Log\LoggerInterface;
@@ -235,7 +235,8 @@ protected function declareEverything(string $queueName = null): array
         return [$queue, $topic];
     }
 
-    protected function getQueueName($queueName = null) {
+    protected function getQueueName($queueName = null)
+    {
         return $queueName ?: $this->queueName;
     }
 

tests/Functional/SendAndReceiveMessageTest.php

@@ -67,7 +67,7 @@ public function test()
 
         $queue->getContext()->purgeQueue($queue->getContext()->createQueue('default'));
 
-        $expectedPayload = __METHOD__ . microtime(true);
+        $expectedPayload = __METHOD__.microtime(true);
 
         $queue->pushRaw($expectedPayload);