extracted new channel lines to a method createChannel().

Author: adm-bome

src/Queue/RabbitMQQueue.php

@@ -84,7 +84,7 @@ public function size($queue = null): int
         }
 
         // create a temporary channel, so the main channel will not be closed on exception
-        $channel = $this->getConnection()->channel();
+        $channel = $this->createChannel();
         [, $size] = $channel->queue_declare($queue, true);
         $channel->close();
 
@@ -277,7 +277,7 @@ public function setConnection(AbstractConnection $connection): RabbitMQQueue
     public function getChannel($forceNew = false): AMQPChannel
     {
         if (! $this->channel || $forceNew) {
-            $this->channel = $this->getConnection()->channel();
+            $this->channel = $this->createChannel();
         }
 
         return $this->channel;
@@ -327,7 +327,7 @@ public function isExchangeExists(string $exchange): bool
 
         try {
             // create a temporary channel, so the main channel will not be closed on exception
-            $channel = $this->getConnection()->channel();
+            $channel = $this->createChannel();
             $channel->exchange_declare($exchange, '', true);
             $channel->close();
 
@@ -401,7 +401,7 @@ public function isQueueExists(string $name = null): bool
     {
         try {
             // create a temporary channel, so the main channel will not be closed on exception
-            $channel = $this->getConnection()->channel();
+            $channel = $this->createChannel();
             $channel->queue_declare($this->getQueue($name), true);
             $channel->close();
 
@@ -476,7 +476,7 @@ public function bindQueue(string $queue, string $exchange, string $routingKey =
     public function purge(string $queue = null): void
     {
         // create a temporary channel, so the main channel will not be closed on exception
-        $channel = $this->getConnection()->channel();
+        $channel = $this->createChannel();
         $channel->queue_purge($this->getQueue($queue));
         $channel->close();
     }
@@ -733,4 +733,9 @@ protected function publishBatch(): void
     {
         $this->getChannel()->publish_batch();
     }
+
+    protected function createChannel(): AMQPChannel
+    {
+        return $this->getConnection()->channel();
+    }
 }