变更

kiri-engine/Pool/Pool.php

@@ -64,6 +64,7 @@ class Pool extends Component
 				$connection->stopHeartbeatCheck();
 			}
 		}
+		$this->logger->warning('channel status', $channel->stats());
 	}
 
 

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()
+		];
 	}