变更
This commit is contained in:
@@ -59,11 +59,6 @@ class Pool extends Component
|
|||||||
$connection->stopHeartbeatCheck();
|
$connection->stopHeartbeatCheck();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (\Kiri::isWorker() || \Kiri::isTask()) {
|
|
||||||
$state = json_encode($channel->stats(), JSON_UNESCAPED_UNICODE);
|
|
||||||
|
|
||||||
$this->logger->warning('channel status(' . env('environmental_workerId') . '): ' . $state);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user