Job.php

<?php

namespace wh\queue;

use Yii;

class Job
{
    protected $queueObject;

    protected $payload;

    protected $queueName;

    public function __construct($queueObject, $payload, $queueName)
    {
        $this->queueObject = $queueObject;
        $this->payload = $payload;
        $this->queueName = $queueName;
    }

    public function run()
    {
        $this->resolveAndRun(json_decode($this->payload, true));
    }

    public function getQueueObject()
    {
        return $this->queueObject;
    }

    protected function resolveAndRun(array $payload)
    {
        list($class, $method) = $this->resolveJob($payload['job']);
        $instance = Yii::createObject([
            'class' => $class
        ]);
        $instance->{$method}($this, $payload['data']);
    }

    protected function resolveJob($job)
    {
        $segments = explode('@', $job);
        return count($segments) > 1 ? $segments : array($segments[0], 'run');
    }
}