<?php // +---------------------------------------------------------------------- // | ThinkPHP [ WE CAN DO IT JUST THINK IT ] // +---------------------------------------------------------------------- // | Copyright (c) 2006-2015 http://thinkphp.cn All rights reserved. // +---------------------------------------------------------------------- // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 ) // +---------------------------------------------------------------------- // | Author: yunwuxin <448901948@qq.com> // +---------------------------------------------------------------------- namespace think\queue\job; use think\queue\Job; class Sync extends Job { /** * The queue message data. * * @var string */ protected $payload; public function __construct($payload) { $this->payload = $payload; } /** * Fire the job. * @return void */ public function fire() { $this->resolveAndFire(json_decode($this->payload, true)); } /** * Get the number of times the job has been attempted. * @return int */ public function attempts() { return 1; } /** * Get the raw body string for the job. * @return string */ public function getRawBody() { return $this->payload; } }