更新文档

Author: Yurunsoft

README.md

@@ -83,6 +83,39 @@
 ]
 ```
 
+### 消费者类
+
+```php
+<?php
+namespace ImiApp\Consumer;
+
+use Imi\Log\Log;
+use Imi\Bean\Annotation\Bean;
+use Imi\Queue\Contract\IMessage;
+use Imi\Queue\Driver\IQueueDriver;
+use Imi\Queue\Service\BaseQueueConsumer;
+
+/**
+ * @Bean("AConsumer")
+ */
+class AConsumer extends BaseQueueConsumer
+{
+    /**
+     * 处理消费
+     * 
+     * @param \Imi\Queue\Contract\IMessage $message
+     * @param \Imi\Queue\Driver\IQueueDriver $queue
+     * @return void
+     */
+    protected function consume(IMessage $message, IQueueDriver $queue)
+    {
+        Log::info(sprintf('[%s]%s:%s', $queue->getName(), $message->getMessageId(), $message->getMessage()));
+        $queue->success($message);
+    }
+
+}
+```
+
 ### 获取队列对象
 
 ```php