diff --git a/kiri-engine/Pool/Pool.php b/kiri-engine/Pool/Pool.php index a26e676c..10decdcc 100644 --- a/kiri-engine/Pool/Pool.php +++ b/kiri-engine/Pool/Pool.php @@ -64,6 +64,7 @@ class Pool extends Component $connection->stopHeartbeatCheck(); } } + $this->logger->warning('channel status', $channel->stats()); } diff --git a/kiri-engine/Pool/SplQueue.php b/kiri-engine/Pool/SplQueue.php index c7410d1c..1c4e390f 100644 --- a/kiri-engine/Pool/SplQueue.php +++ b/kiri-engine/Pool/SplQueue.php @@ -72,7 +72,11 @@ class SplQueue implements QueueInterface public function stats(): array { // TODO: Implement stats() method. - return []; + return [ + 'consumer_num' => 0, + 'producer_num' => 0, + 'queue_num' => $this->length() + ]; }