fix: reconnect connection after publish action

dojiland · Jan 7, 2020 · e44ba29 · e44ba29
1 parent 1fc78fa
commit e44ba29
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/nsqphp.php b/src/nsqphp.php
@@ -297,8 +297,6 @@ public function publish($topic, MessageInterface $msg)
                 }, $conn, 2);
             } catch (\Exception $e) {
                 $errors[] = $e->getMessage();
-            } finally {
-                $conn->close();
             }
             if ($success >= $this->pubSuccessCount) {
                 break;
@@ -323,6 +321,7 @@ public function tryFunc(Callable $func, ConnectionInterface $conn, $tries = 1)
                 return;
             } catch (\Exception $e) {
                 $lastException = $e;
+            } finally {
                 $conn->reconnect();
             }
         }