PrintAccessor.php 403 B

123456789101112131415161718192021
  1. <?php
  2. namespace app\queue\redis;
  3. use Webman\RedisQueue\Consumer;
  4. class PrintAccessor implements Consumer
  5. {
  6. // 要消费的队列名
  7. public $queue = 'access';
  8. // 连接名,对应 plugin/webman/redis-queue/redis.php 里的连接`
  9. public $connection = 'default';
  10. // 消费
  11. public function consume($data)
  12. {
  13. // 无需反序列化
  14. var_export($data);
  15. }
  16. }