webman-exercise/app/queue/beanstalk/SmsConsumer.php

<?php

namespace app\queue\beanstalk;

use Vanderw\BeanstalkQueue\Consumer;
use Vanderw\BeanstalkQueue\Client;

class SmsConsumer implements Consumer
{
    // 要消费的队列名
    public $tube = 'sms_consumer';
    // reserve 操作的超時秒數
    public $reserve_timeout =10;
    // 指示退出訂閱
    public $quit = false;
    // 连接名，对应 plugin/webman/beanstalk-queue/beanstalk.php 里的连接`
    public $connection = 'default';

    // 消费
    public function consume($job)
    {
        $data = $job->getData();
        if (is_null($data)) {
            // Log
            return;
        }
        // processing

        $data = json_decode($data, true);
        print_r($data);
        
        Client::delete($job);
    }
}