Update RedisConnection.php

webman-php · Jun 3, 2022 · 4c900f8 · 4c900f8
1 parent 27d2280
commit 4c900f8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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');
             });