Remove deprecated codes (#5812)

Author: huangdijia

src/Driver/RedisDriver.php

@@ -14,7 +14,6 @@
 use Hyperf\AsyncQueue\Exception\InvalidQueueException;
 use Hyperf\AsyncQueue\JobInterface;
 use Hyperf\AsyncQueue\JobMessage;
-use Hyperf\AsyncQueue\Message;
 use Hyperf\AsyncQueue\MessageInterface;
 use Hyperf\Redis\RedisFactory;
 use Hyperf\Redis\RedisProxy;

src/Message.php

@@ -23,29 +23,8 @@
  * @coversNothing
  */
 #[CoversNothing]
-class MessageTest extends TestCase
+class JobMessageTest extends TestCase
 {
-    public function testMessageSerialize()
-    {
-        system(__DIR__ . '/async_queue2.2');
-
-        $message = unserialize(file_get_contents(__DIR__ . '/message2.2.cache'));
-
-        $this->assertInstanceOf(MessageInterface::class, $message);
-        $this->assertInstanceOf(JobInterface::class, $message->job());
-        $this->assertInstanceOf(JobInterface::class, $message->job());
-        $this->assertInstanceOf(DemoJob::class, $message->job());
-        $this->assertSame(9501, $message->job()->id);
-
-        $serialized = serialize($message);
-        $message = unserialize($serialized);
-        $this->assertInstanceOf(MessageInterface::class, $message);
-        $this->assertInstanceOf(JobInterface::class, $message->job());
-        $this->assertInstanceOf(JobInterface::class, $message->job());
-        $this->assertInstanceOf(DemoJob::class, $message->job());
-        $this->assertSame(9501, $message->job()->id);
-    }
-
     public function testJobMessageSerialize()
     {
         $id = rand(0, 9999);

tests/MessageTest.php renamed to tests/JobMessageTest.php

@@ -14,7 +14,6 @@
 use Hyperf\AsyncQueue\Driver\ChannelConfig;
 use Hyperf\AsyncQueue\Driver\RedisDriver;
 use Hyperf\AsyncQueue\JobMessage;
-use Hyperf\AsyncQueue\Message;
 use Hyperf\Codec\Packer\PhpSerializerPacker;
 use Hyperf\Context\ApplicationContext;
 use Hyperf\Context\Context;
@@ -52,15 +51,15 @@ public function testDriverPush()
 
         $id = uniqid();
         $driver->push(new DemoJob($id));
-        /** @var Message $class */
+        /** @var JobMessage $class */
         $class = $packer->unpack((string) Context::get('test.async-queue.lpush.value'));
         $this->assertSame($id, $class->job()->id);
         $key = Context::get('test.async-queue.lpush.key');
         $this->assertSame('test:waiting', $key);
 
         $id = uniqid();
         $driver->push(new DemoJob($id), 5);
-        /** @var Message $class */
+        /** @var JobMessage $class */
         $class = $packer->unpack((string) Context::get('test.async-queue.zadd.value'));
         $this->assertSame($id, $class->job()->id);
         $key = Context::get('test.async-queue.zadd.key');
@@ -118,7 +117,7 @@ public function testAsyncQueueJobGenerate()
         $serialized = (string) Context::get('test.async-queue.lpush.value');
         $this->assertSame(231, strlen($serialized));
 
-        /** @var Message $class */
+        /** @var JobMessage $class */
         $class = $packer->unpack($serialized);
 
         $this->assertSame($id, $class->job()->id);