remove unnecessary code and fix style

Author: iamfarhad

composer.json

@@ -15,7 +15,8 @@
         "orchestra/testbench": "^v7.18.0",
         "squizlabs/php_codesniffer": "^3.7",
         "mockery/mockery": "^1.5.1",
-        "dg/bypass-finals": "dev-master"
+        "dg/bypass-finals": "dev-master",
+        "rector/rector": "^0.15.3"
     },
     "autoload": {
         "psr-4": {

src/Connectors/RabbitMQConnector.php

@@ -2,13 +2,13 @@
 
 namespace iamfarhad\LaravelRabbitMQ\Connectors;
 
-use iamfarhad\LaravelRabbitMQ\RabbitQueue;
-use Illuminate\Contracts\Events\Dispatcher;
-use Illuminate\Contracts\Queue\Queue;
 use Illuminate\Queue\Connectors\ConnectorInterface;
-use Illuminate\Queue\Events\WorkerStopping;
-use PhpAmqpLib\Connection\AMQPConnectionConfig;
 use PhpAmqpLib\Connection\AMQPConnectionFactory;
+use PhpAmqpLib\Connection\AMQPConnectionConfig;
+use Illuminate\Contracts\Events\Dispatcher;
+use Illuminate\Queue\Events\WorkerStopping;
+use iamfarhad\LaravelRabbitMQ\RabbitQueue;
+use Illuminate\Contracts\Queue\Queue;
 
 class RabbitMQConnector implements ConnectorInterface
 {

src/Console/ConsumeCommand.php

@@ -2,10 +2,9 @@
 
 namespace iamfarhad\LaravelRabbitMQ\Console;
 
+use Symfony\Component\Console\Attribute\AsCommand;
 use Illuminate\Queue\Console\WorkCommand;
 use Illuminate\Support\Str;
-use iamfarhad\LaravelRabbitMQ\Consumer;
-use Symfony\Component\Console\Attribute\AsCommand;
 
 #[AsCommand(name: 'rabbitmq:consume')]
 final class ConsumeCommand extends WorkCommand

src/Jobs/RabbitMQJob.php

@@ -2,16 +2,13 @@
 
 namespace iamfarhad\LaravelRabbitMQ\Jobs;
 
-use Illuminate\Container\Container;
-use Illuminate\Contracts\Container\BindingResolutionException;
 use Illuminate\Contracts\Queue\Job as JobContract;
+use iamfarhad\LaravelRabbitMQ\RabbitQueue;
+use Illuminate\Container\Container;
+use PhpAmqpLib\Message\AMQPMessage;
 use Illuminate\Queue\Jobs\Job;
 use Illuminate\Support\Arr;
 use JsonException;
-use PhpAmqpLib\Exception\AMQPProtocolChannelException;
-use PhpAmqpLib\Message\AMQPMessage;
-use PhpAmqpLib\Wire\AMQPTable;
-use iamfarhad\LaravelRabbitMQ\RabbitQueue;
 
 final class RabbitMQJob extends Job implements JobContract
 {
@@ -131,9 +128,6 @@ public function getRabbitMQMessage(): AMQPMessage
 
     private function getRabbitMQMessageHeaders(): ?array
     {
-        /*
-         * @var AMQPTable|null $headers
-         */
         if (! $headers = Arr::get($this->amqpMessage->get_properties(), 'application_headers')) {
             return null;
         }

src/LaravelRabbitQueueServiceProvider.php

@@ -5,7 +5,6 @@
 use iamfarhad\LaravelRabbitMQ\Connectors\RabbitMQConnector;
 use iamfarhad\LaravelRabbitMQ\Console\ConsumeCommand;
 use Illuminate\Contracts\Debug\ExceptionHandler;
-use Illuminate\Queue\QueueManager;
 use Illuminate\Support\ServiceProvider;
 
 final class LaravelRabbitQueueServiceProvider extends ServiceProvider
@@ -20,7 +19,7 @@ public function register(): void
         if ($this->app->runningInConsole()) {
             $this->app->singleton(
                 'rabbitmq.consumer',
-                function (): \iamfarhad\LaravelRabbitMQ\Consumer {
+                function (): Consumer {
                     $isDownForMaintenance = fn(): bool => $this->app->isDownForMaintenance();
 
                     return new Consumer(
@@ -34,7 +33,7 @@ function (): \iamfarhad\LaravelRabbitMQ\Consumer {
 
             $this->app->singleton(
                 ConsumeCommand::class,
-                static fn($app): \iamfarhad\LaravelRabbitMQ\Console\ConsumeCommand => new ConsumeCommand(
+                static fn($app): ConsumeCommand => new ConsumeCommand(
                     $app['rabbitmq.consumer'],
                     $app['cache.store']
                 )
@@ -50,11 +49,8 @@ function (): \iamfarhad\LaravelRabbitMQ\Consumer {
 
     public function boot(): void
     {
-        /*
-         * @var QueueManager $queue
-         */
         $queue = $this->app['queue'];
 
-        $queue->addConnector('rabbitmq', fn(): \iamfarhad\LaravelRabbitMQ\Connectors\RabbitMQConnector => new RabbitMQConnector($this->app['events']));
+        $queue->addConnector('rabbitmq', fn(): RabbitMQConnector => new RabbitMQConnector($this->app['events']));
     }
 }

src/RabbitQueue.php

@@ -2,29 +2,29 @@
 
 namespace iamfarhad\LaravelRabbitMQ;
 
-use ErrorException;
-use Exception;
-use iamfarhad\LaravelRabbitMQ\Connectors\RabbitMQConnector;
-use iamfarhad\LaravelRabbitMQ\Jobs\RabbitMQJob;
-use Illuminate\Queue\Queue;
-use Illuminate\Contracts\Queue\Queue as QueueContract;
-use Illuminate\Support\Arr;
-use Illuminate\Support\Str;
-use JsonException;
-use PhpAmqpLib\Channel\AMQPChannel;
-use PhpAmqpLib\Connection\AbstractConnection;
-use PhpAmqpLib\Exception\AMQPChannelClosedException;
 use PhpAmqpLib\Exception\AMQPConnectionClosedException;
+use Illuminate\Contracts\Queue\Queue as QueueContract;
 use PhpAmqpLib\Exception\AMQPProtocolChannelException;
+use PhpAmqpLib\Exception\AMQPChannelClosedException;
+use iamfarhad\LaravelRabbitMQ\Jobs\RabbitMQJob;
 use PhpAmqpLib\Exception\AMQPRuntimeException;
+use PhpAmqpLib\Connection\AbstractConnection;
 use PhpAmqpLib\Exchange\AMQPExchangeType;
+use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Message\AMQPMessage;
 use PhpAmqpLib\Wire\AMQPTable;
+use Illuminate\Queue\Queue;
+use Illuminate\Support\Arr;
+use Illuminate\Support\Str;
+use ErrorException;
+use JsonException;
+use Exception;
 use Throwable;
 
 class RabbitQueue extends Queue implements QueueContract
 {
     private AMQPChannel $amqpChannel;
+
     private RabbitMQJob $rabbitMQJob;
 
     public function __construct(