Auto reconnect when the socket disconnected (#349)

Co-authored-by: Deeka Wong <[email protected]>
friendsofhyperf · Sep 22, 2023 · 882b888 · 882b888
1 parent c94e222
commit 882b888
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Consumer.php b/src/Consumer.php
@@ -24,7 +24,7 @@
 use Hyperf\Coroutine\Coroutine;
 use MySQLReplication\Config\ConfigBuilder;
 use MySQLReplication\MySQLReplicationFactory;
-use Throwable;
+use MySQLReplication\Socket\SocketException;
 
 use function Hyperf\Support\make;
 use function Hyperf\Tappable\tap;
@@ -100,8 +100,8 @@ public function start(): void
 
                 try {
                     $replication->consume();
-                } catch (Throwable $e) {
-                    $this->warning((string) $e);
+                } catch (SocketException $e) {
+                    $replication->connect();
                 }
             }
         };