fix(async-queue): relax type hint for callback message parameter (#7602)

Author: huangdijia

src/Driver/Driver.php

@@ -105,30 +105,31 @@ protected function checkQueueLength(): void
 
     /**
      * @param mixed $data
-     * @param MessageInterface $message
+     * @param MessageInterface|mixed $message
      */
     protected function getCallback($data, $message): callable
     {
         return function () use ($data, $message) {
             try {
-                if ($message instanceof MessageInterface) {
-                    $this->event?->dispatch(new BeforeHandle($message));
+                // If the message is invalid, just ack it.
+                if (! $message instanceof MessageInterface) {
+                    $this->ack($data);
+                    return;
+                }
 
-                    $result = $message->job()->handle();
+                $this->event?->dispatch(new BeforeHandle($message));
 
-                    match ($result) {
-                        Result::REQUEUE => $this->remove($data) && $this->retry($data),
-                        Result::RETRY => $this->remove($data) && $message->attempts() && $this->retry($message),
-                        Result::DROP => $this->remove($data),
-                        Result::ACK => $this->ack($data),
-                        default => $this->ack($data),
-                    };
+                $result = $message->job()->handle();
 
-                    $this->event?->dispatch(new AfterHandle($message));
-                } else {
-                    // If the message is invalid, just ack it.
-                    $this->ack($data);
-                }
+                match ($result) {
+                    Result::REQUEUE => $this->remove($data) && $this->retry($data),
+                    Result::RETRY => $this->remove($data) && $message->attempts() && $this->retry($message),
+                    Result::DROP => $this->remove($data),
+                    Result::ACK => $this->ack($data),
+                    default => $this->ack($data),
+                };
+
+                $this->event?->dispatch(new AfterHandle($message, $result instanceof Result ? $result : null));
             } catch (Throwable $ex) {
                 if (isset($message, $data)) {
                     if ($message->attempts() && $this->remove($data)) {

src/Event/AfterHandle.php

@@ -12,6 +12,13 @@
 
 namespace Hyperf\AsyncQueue\Event;
 
+use Hyperf\AsyncQueue\MessageInterface;
+use Hyperf\AsyncQueue\Result;
+
 class AfterHandle extends Event
 {
+    public function __construct(MessageInterface $message, public ?Result $result = null)
+    {
+        parent::__construct($message);
+    }
 }