修正

top-think · Mar 9, 2023 · edc326d · edc326d
1 parent 125aade
commit edc326d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/ipc/driver/Redis.php b/src/ipc/driver/Redis.php
@@ -49,6 +49,7 @@ public function subscribe()
 
         Coroutine::create(function () {
             $this->runWithRedis(function (PHPRedis $redis) {
+                $redis->setOption(PHPRedis::OPT_READ_TIMEOUT, -1);
                 $redis->subscribe([$this->getPrefix() . $this->workerId], function ($redis, $channel, $message) {
                     $this->manager->triggerEvent('message', unserialize($message));
                 });