新增消费者弹出、消费前后置事件

Author: Yurunsoft

Diff for: src/Event/Param/ConsumerBeforeConsumeParam.php

@@ -15,4 +15,11 @@ class ConsumerBeforeConsumeParam extends EventParam
      */
     public $queue;
 
+    /**
+     * 消息
+     *
+     * @var \Imi\Queue\Contract\IMessage
+     */
+    public $message;
+
 }

Diff for: src/Service/BaseQueueConsumer.php

@@ -85,6 +85,7 @@ public function start(?int $co = null)
                 {
                     Event::trigger('IMI.QUEUE.CONSUMER.BEFORE_CONSUME', [
                         'queue' =>  $queue,
+                        'message'   =>  $message,
                     ], $this, ConsumerBeforeConsumeParam::class);
                     $this->consume($message, $queue);
                     Event::trigger('IMI.QUEUE.CONSUMER.AFTER_CONSUME', [