Publisher: reconnect if necessary

src/Producer.php

@@ -82,8 +82,8 @@ public function publish(string $body, string $routingKey = '', array $properties
         );
         $message = new AMQPMessage($body, $properties);
 
-        if ($this->reconnectEnabled && false === $this->getConnection()->select(1)) {
-            $this->reconnect();
+        if ($this->reconnectEnabled) {
+            $this->reconnectIfNecessary();
         }
 
         if ($this->isAutoSetupFabricEnabled()) {
@@ -96,4 +96,23 @@ public function publish(string $body, string $routingKey = '', array $properties
             $routingKey
         );
     }
+
+    /**
+     * Check connection an reconnect if necessary
+     */
+    private function reconnectIfNecessary(): void
+    {
+        // for lazy connections:
+        $this->getConnection()->getSocket();
+
+        try {
+            $connected = $this->getConnection()->select(1);
+        } catch (\ErrorException $e) {
+            $connected = false;
+        }
+
+        if (! $connected) {
+            $this->reconnect();
+        };
+    }
 }