modify plugin name

2022-07-11 16:09:58 +08:00
parent 52c6ee7053
commit f77374519e
2 changed files with 20 additions and 1 deletions
@@ -37,7 +37,10 @@ class PoolQueue implements QueueInterface
 	 */
 	public function push(mixed $data, float $timeout = -1): bool
 	{
-		return $this->queue->push($data, $timeout);
+		if (!$this->isClose()) {
+			return $this->queue->push($data, $timeout);
+		}
+		return false;
 	}