Try to reconnect on socket error (broken pipe mostly) (#50)

contributte · Jun 8, 2021 · e07d274 · e07d274
1 parent c4bbc5f
commit e07d274
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/Connection/Connection.php b/src/Connection/Connection.php
@@ -80,7 +80,11 @@ public function getChannel(): Channel
 
 			$this->channel = $channel;
 		} catch (ClientException $e) {
-			if ($e->getMessage() !== 'Broken pipe or closed connection.') {
+			if (!in_array(
+				$e->getMessage(),
+				['Broken pipe or closed connection.', 'Could not write data to socket.'],
+				true
+			)) {
 				throw new ConnectionException($e->getMessage(), $e->getCode(), $e);
 			}