Removed deprecated code. (#2648)

* Removed deprecated code.

* Update

Author: limingxinleo

src/Driver/Driver.php

@@ -19,6 +19,7 @@
 use Hyperf\AsyncQueue\Exception\InvalidPackerException;
 use Hyperf\AsyncQueue\MessageInterface;
 use Hyperf\Contract\PackerInterface;
+use Hyperf\Process\ProcessManager;
 use Hyperf\Utils\Arr;
 use Hyperf\Utils\Coroutine\Concurrent;
 use Hyperf\Utils\Packer\PhpSerializerPacker;
@@ -27,12 +28,6 @@
 
 abstract class Driver implements DriverInterface
 {
-    /**
-     * @var bool
-     * @deprecated v2.1 use ProcessManager::isRunning() instead.
-     */
-    public static $running = true;
-
     /**
      * @var ContainerInterface
      */
@@ -85,7 +80,7 @@ public function consume(): void
         $messageCount = 0;
         $maxMessages = Arr::get($this->config, 'max_messages', 0);
 
-        while (self::$running) {
+        while (ProcessManager::isRunning()) {
             [$data, $message] = $this->pop();
 
             if ($data === false) {

src/Signal/DriverStopHandler.php

@@ -11,9 +11,12 @@
  */
 namespace Hyperf\AsyncQueue\Signal;
 
-use Hyperf\AsyncQueue\Driver\Driver;
+use Hyperf\Process\ProcessManager;
 use Hyperf\Signal\SignalHandlerInterface;
 
+/**
+ * @deprecated v2.2 use Hyperf\Process\Handler\ProcessStopHandler instead.
+ */
 class DriverStopHandler implements SignalHandlerInterface
 {
     public function listen(): array
@@ -25,6 +28,6 @@ public function listen(): array
 
     public function handle(int $signal): void
     {
-        Driver::$running = false;
+        ProcessManager::setRunning(false);
     }
 }