Update Heartbeat.php

mondagPHP · web-flow · commit 2007fa900115 · 2021-07-26T17:18:51.000+08:00
diff --git a/src/bootstrap/Heartbeat.php b/src/bootstrap/Heartbeat.php
@@ -25,6 +25,10 @@ public static function start(Worker $worker)
         }
         Timer::add(HEARTBEAT_TIME, function () use ($database) {
             foreach ($database ?? [] as $connectionName => $value) {
+                //默认没有配置也是加入心跳
+                if (isset($value['is_beat']) && ! $value['is_beat']) {
+                    continue;
+                }
                 HeroDB::connection($connectionName)->select('select 1 limit 1');
             }
         });

Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,10 @@ public static function start(Worker $worker)`
`25`	`25`	`}`
`26`	`26`	`Timer::add(HEARTBEAT_TIME, function () use ($database) {`
`27`	`27`	`foreach ($database ?? [] as $connectionName => $value) {`
	`28`	`+ //默认没有配置也是加入心跳`
	`29`	`+ if (isset($value['is_beat']) && ! $value['is_beat']) {`
	`30`	`+ continue;`
	`31`	`+ }`
`28`	`32`	`HeroDB::connection($connectionName)->select('select 1 limit 1');`
`29`	`33`	`}`
`30`	`34`	`});`