feat: Add stop condition in HealthMonitor (#710)

Co-authored-by: Deeka Wong <[email protected]>
friendsofhyperf · Sep 11, 2024 · f83d4a8 · f83d4a8
1 parent 17c4632
commit f83d4a8
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/Monitor/HealthMonitor.php b/src/Monitor/HealthMonitor.php
@@ -55,6 +55,10 @@ public function process(): void
 
             // Monitor binLogCurrent
             $this->timer->tick($this->monitorInterval, function () {
+                if ($this->consumer->isStopped()) {
+                    return Timer::STOP;
+                }
+
                 if ($this->binLogCurrent instanceof BinLogCurrent) {
                     $this->logger?->debug(
                         '[{connection}] Health monitoring, binLogCurrent: [{binlog_current}]',
@@ -68,6 +72,10 @@ public function process(): void
 
             // Health check and set snapshot
             $this->timer->tick($this->snapShortInterval, function () {
+                if ($this->consumer->isStopped()) {
+                    return Timer::STOP;
+                }
+
                 if (! $this->binLogCurrent instanceof BinLogCurrent) {
                     return;
                 }