<?php

namespace app\queue\redis\fast;

use Webman\RedisQueue\Consumer;
use app\admin\service\warn\PoundbillWarningCheckMethods;

class ReceivingPoundbillWarning implements Consumer
{
    // 要消费的队列名
    public $queue = 'ReceivingPoundbillWarning';

    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    // 收料
    public function consume($data)
    {
        (new PoundbillWarningCheckMethods())->ReceivingAnalyze($data);
    }
}