bug fixed

kcloze · Jan 9, 2018 · b629376 · b629376
1 parent ea8ecc8
commit b629376
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Process.php b/src/Process.php
@@ -245,8 +245,13 @@ public function registTimer()
         \Swoole\Timer::tick($this->queueTickTimer, function ($timerId) {
             $topics = $this->topics;
             $this->status  =$this->getMasterData('status');
+            if (empty($this->workers) && Process::STATUS_WAIT == $this->status) {
+                $this->exitMaster();
+            }
             $this->queue   = Queue::getQueue($this->config['job']['queue'], $this->logger);
             if (empty($this->queue)) {
+                $this->logger->log('queue connection is lost', 'info', $this->logSaveFileWorker);
+
                 return;
             }
             $this->queue->setTopics($topics);