Bugfixed client reconnection logic

2024-03-01 19:27:46 +01:00
parent 1255db21ab
commit 9bd53062b0
1 changed files with 4 additions and 2 deletions
--- a/src/CommandBusClient.php
+++ b/src/CommandBusClient.php
@@ -53,15 +53,17 @@ class CommandBusClient implements CommandBusInterface
    public function close(): void
    {
        $this->autoReconnect = false;
-        $this->connection->close();
+        $this->connection->end();
        $this->connection->removeAllListeners();
        $this->connection = null;
    }

    private function reconnect(): void
    {
+        if ($this->isReconnecting) return;
+
        if ($this->connection) {
-            $this->connection->close();
+            $this->connection->end();
            $this->connection->removeAllListeners();
            $this->connection = null;
        }