refactor and fix pipeline

Author: danuiachimovschi

src/Infrastructure/Rabbitmq/Consumer/FanoutConsumerCommand.php

@@ -5,7 +5,6 @@
 namespace App\Infrastructure\Rabbitmq\Consumer;
 
 use App\Infrastructure\Rabbitmq\RabbitmqConnection;
-use PhpAmqpLib\Connection\AMQPStreamConnection;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;

src/Infrastructure/Rabbitmq/Consumer/HeaderConsumerCommand.php

@@ -33,7 +33,13 @@ protected function execute(InputInterface $input, OutputInterface $output): neve
         $connection = $this->rabbitmqConnection->getConnection();
         $channel = $connection->channel();
 
-        $channel->exchange_declare(self::EXCHANGE_NAME, 'headers', false, true, false, false, false, arguments: new AMQPTable(['x-max-priority' => 10]));
+        $channel->exchange_declare(
+            exchange: self::EXCHANGE_NAME,
+            type: 'headers',
+            durable: true,
+            auto_delete: false,
+            arguments: new AMQPTable(['x-max-priority' => 10])
+        );
 
         [$queue_name, ,] = $channel->queue_declare(self::QUEUE_NAME, false, true, true, false);
 

src/Infrastructure/Rabbitmq/Producer/HeaderProducerCommand.php

@@ -35,7 +35,13 @@ protected function execute(InputInterface $input, OutputInterface $output): int
         $connection = $this->rabbitmqConnection->getConnection();
         $channel = $connection->channel();
 
-        $channel->exchange_declare(self::EXCHANGE_NAME, 'headers', false, true, false, false, false, arguments: new AMQPTable(['x-max-priority' => 10]));
+        $channel->exchange_declare(
+            exchange: self::EXCHANGE_NAME,
+            type: 'headers',
+            durable: true,
+            auto_delete: false,
+            arguments: new AMQPTable(['x-max-priority' => 10])
+        );
 
         foreach (range(1, 1000) as $i) {
             $msg = new AMQPMessage(json_encode(['Hello World! ' . $i]));

src/Infrastructure/Rabbitmq/Producer/TopicProducerCommand.php

@@ -5,7 +5,6 @@
 namespace App\Infrastructure\Rabbitmq\Producer;
 
 use App\Infrastructure\Rabbitmq\RabbitmqConnection;
-use PhpAmqpLib\Connection\AMQPStreamConnection;
 use PhpAmqpLib\Message\AMQPMessage;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;