diff --git a/src/RedisConnection.php b/src/RedisConnection.php index b87e66f..8a2c9fa 100644 --- a/src/RedisConnection.php +++ b/src/RedisConnection.php @@ -14,6 +14,7 @@ namespace Webman\RedisQueue; use Workerman\Timer; +use Workerman\Worker; class RedisConnection extends \Redis { @@ -41,7 +42,7 @@ public function connectWithConfig(array $config = []) if (!empty($this->config['db'])) { $this->select($this->config['db']); } - if (!$timer) { + if (Worker::getAllWorkers() && !$timer) { $timer = Timer::add($this->config['ping'] ?? 55, function () { $this->execCommand('ping'); });