Skip to content

Commit

Permalink
更新
Browse files Browse the repository at this point in the history
  • Loading branch information
yunwuxin committed Aug 16, 2016
1 parent 5eaa66a commit 564bea5
Showing 1 changed file with 9 additions and 11 deletions.
20 changes: 9 additions & 11 deletions src/driver/Topthink.php
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@

namespace think\queue\driver;


use think\exception\HttpException;
use think\Request;
use think\queue\job\Topthink as TopthinkJob;
Expand All @@ -20,15 +19,14 @@
class Topthink
{
protected $options = [
'token' => '',
'project_id' => '',
'protocol' => 'http',
'host' => 'qns.topthink.com',
'port' => '80',
'api_version' => '3',
'max_retries' => 3,
'encryption_key' => '',
'default' => 'default'
'token' => '',
'project_id' => '',
'protocol' => 'http',
'host' => 'qns.topthink.com',
'port' => 80,
'api_version' => 1,
'max_retries' => 3,
'default' => 'default'
];

/** @var Request */
Expand Down Expand Up @@ -209,7 +207,7 @@ protected function createPayload($job, $data = '')
*/
protected function marshalPushedJob()
{
return (object)[
return (object) [
'id' => $this->request->header('topthink-message-id'),
'payload' => $this->request->getContent(),
'attempts' => $this->request->header('topthink-message-attempts')
Expand Down

0 comments on commit 564bea5

Please sign in to comment.