arakaki-yuji/backjob

此包的最新版本(0.0.5)没有可用的许可信息。

这是一个作业队列库

0.0.5 2019-07-10 02:04 UTC

This package is auto-updated.

Last update: 2024-09-10 22:02:24 UTC


README

使用Azure Queue Storage的作业队列库。

安装

将arakaki-yuji/backjob包含到您的项目中,通过将其添加到您的composer.json文件中。

{
    "require": {
        "arakaki-yuji/backjob": "^0.0.5"
    }
}

使用方法

定义您自己的作业

class CustomJob extends \Backjob\Job
{
    /**
     * You must define a run method.
     * this method is called when dequeued and run
     */
    public function run()
    {
        $msg = $this->params['message'];
        return $msg;
    }
    
    /**
     * this method is optional.
     * if you define success method, it is called after run method successed.
     */
    public function success()
    {
        return 'success job';
    }
    
     /**
     * this method is optional.
     * if you define fail method, it is called after run method failed.
     */
    public function fail()
    {
        return 'success job';
    }
}

入队、出队并运行作业。

设置backjob实例。

$backjob = new \Backjob\Backjob::factory($storageAccountName, $queueName, $accessKey);

入队作业

$params = ['message' => 'Hello Backjob'];
$job = CustomeJob::makeJob($params);
$backjob->queue($job);

出队并运行作业。

$backjob = new \Backjob\Backjob::factory($storageAccountName, $queueName, $accessKey);
$backjob->run(); // => 'Hello Backjob'