ACP2E-2138: [Cloud]RabbitMQ Broken pipe or closed connection errors during indexing

dhorytskyi · dhorytskyi · commit 357c282365fc · 2023-08-20T15:30:54.000-05:00
diff --git a/lib/internal/Magento/Framework/Amqp/Config.php b/lib/internal/Magento/Framework/Amqp/Config.php
@@ -176,6 +176,9 @@ public function getChannel()
             || !$this->channel->getConnection()
             || !$this->channel->getConnection()->isConnected()
         ) {
+            if (!$this->connection->isConnected()) {
+                $this->connection->reconnect();
+            }
             $this->channel = $this->connection->channel();
         }
 

Original file line number	Diff line number	Diff line change
`@@ -176,6 +176,9 @@ public function getChannel()`
`176`	`176`	`\|\| !$this->channel->getConnection()`
`177`	`177`	`\|\| !$this->channel->getConnection()->isConnected()`
`178`	`178`	`) {`
	`179`	`+ if (!$this->connection->isConnected()) {`
	`180`	`+ $this->connection->reconnect();`
	`181`	`+ }`
`179`	`182`	`$this->channel = $this->connection->channel();`
`180`	`183`	`}`
`181`	`184`