update event

src/Dispatcher.php

@@ -21,10 +21,10 @@
  *
  * @event patrolling    进行一次僵尸进程检查周期
  *
- * @event received      从消息队列收到一条消息
+ * @event consumed      从消息队列消费了一条消息
  *                      参数: array $message, Dispatcher $master
  *
- * @event processed     一条amqp消息被worker成功处理
+ * @event processed     一条队列消息被worker成功处理
  *                      参数: string $workerID, Dispatcher $master
  *
  * @event workerExit    worker退出
@@ -301,7 +301,6 @@ public function onConsume(
             ],
             'content' => $AMQPMessage->content,
         ];
-        $this->errorlessEmit('received', [$message]);
 
         if ($reachedBefore) {
             $this->cachedMessages->push($message);
@@ -482,6 +481,7 @@ private function dispatch(array $message): string
         }
         $this->stat['consumed']++;
         $this->workersInfo[$workerID]['sent']++;
+        $this->errorlessEmit('consumed', [$message]);
 
         return $workerID;
     }