变更
This commit is contained in:
@@ -64,7 +64,11 @@ class Pool extends Component
|
|||||||
$connection->stopHeartbeatCheck();
|
$connection->stopHeartbeatCheck();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
$this->logger->warning('channel status', $channel->stats());
|
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