Fixed first heartbeat

swoole · Aug 28, 2023 · 9543e81 · 9543e81
1 parent 89ce747
commit 9543e81
Showing 1 changed file with 12 additions and 2 deletions.
diff --git a/src/Consumer/Consumer.php b/src/Consumer/Consumer.php
@@ -411,11 +411,21 @@ protected function heartbeat(): void
         }
     }
 
+    protected function getLastHeartbeatTime(): float
+    {
+        return $this->lastHeartbeatTime > 0 ? $this->lastHeartbeatTime : microtime(true);
+    }
+
+    protected function setLastHeartbeatTime(float $lastHeartbeatTime): void
+    {
+        $this->lastHeartbeatTime = $lastHeartbeatTime;
+    }
+
     protected function checkBeartbeat(): void
     {
         $time = microtime(true);
-        if ($time - $this->lastHeartbeatTime >= $this->config->getGroupHeartbeat()) {
-            $this->lastHeartbeatTime = $time;
+        if ($time - $this->getLastHeartbeatTime() >= $this->config->getGroupHeartbeat()) {
+            $this->setLastHeartbeatTime($time);
             $this->heartbeat();
         }
     }