release version 2.0.1

samdark · samdark · commit 5e3bc6c389c4 · 2017-11-13T22:49:43.000+03:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,23 +1,23 @@
 Yii2 Queue Extension Change Log
 ===============================
 
-## 2.0.1 under development
+## 2.0.1, November 13, 2017
 
+- Bug #98: Fixed timeout error handler (zhuravljov)
+- Bug #112: Queue command inside module (tsingsun)
+- Bug #118: Synchronized moving of delayed and reserved jobs to waiting list (zhuravljov)
+- Bug #155: Slave DB breaks listener (zhuravljov)
+- Enh #97: `Queue::status` is public method (zhuravljov)
+- Enh #116: Add Chinese Guide (kids-return)
+- Enh #122: Rename `Job` to `JobInterface` (zhuravljov)
+- Enh #137: All throwable errors caused by jobs are now caught (brandonkelly)
 - Enh #141: Clear and remove commands for File, DB, Beanstalk and Redis drivers (zhuravljov)
-- Enh #151: Compatibility with Yii 2.0.13 and PHP 7.2 (zhuravljov)
+- Enh #147: Igbinary job serializer (xutl)
 - Enh #148: Allow to change vhost setting for RabbitMQ (ischenko)
+- Enh #151: Compatibility with Yii 2.0.13 and PHP 7.2 (zhuravljov)
 - Enh #160: Benchmark of job wait time (zhuravljov)
-- Bug #155: Slave DB breaks listener (zhuravljov)
 - Enh: Rename `cli\Verbose` behavior to `cli\VerboseBehavior` (zhuravljov)
-- Enh #147: Igbinary job serializer (xutl)
 - Enh: Rename `serializers\Serializer` interface to `serializers\SerializerInterface` (zhuravljov)
-- Enh #122: Rename `Job` to `JobInterface` (zhuravljov)
-- Bug #118: Synchronized moving of delayed and reserved jobs to waiting list (zhuravljov)
-- Bug #112: Queue command inside module (tsingsun)
-- Enh #116: Add Chinese Guide (kids-return)
-- Enh #97: `Queue::status` is public method (zhuravljov)
-- Bug #98: Fixed timeout error handler (zhuravljov)
-- Enh #137: All throwable errors caused by jobs are now caught (brandonkelly)
 - Enh: Added `Signal::setExitFlag()` to stop `Queue::run()` loop manually (silverfire)
 
 ## 2.0.0
@@ -96,3 +96,6 @@ Yii2 Queue Extension Change Log
 - Enh: Add exchange for AMQP driver (airani)
 - Enh: Beanstalk driver (zhuravljov)
 - Enh: Added English docs (samdark)
+
+
+
diff --git a/src/LogBehavior.php b/src/LogBehavior.php
@@ -26,6 +26,7 @@ class LogBehavior extends Behavior
      */
     public $autoFlush = true;
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/Queue.php b/src/Queue.php
@@ -78,6 +78,7 @@ abstract class Queue extends Component
     private $pushDelay;
     private $pushPriority;
 
+
     /**
      * @inheritdoc
      */
@@ -173,7 +174,7 @@ abstract protected function pushMessage($message, $ttr, $delay, $priority);
      * @param string $message
      * @param int $ttr time to reserve
      * @param int $attempt number
-     * @return boolean
+     * @return bool
      */
     protected function handleMessage($id, $message, $ttr, $attempt)
     {
diff --git a/src/cli/Action.php b/src/cli/Action.php
@@ -27,6 +27,7 @@ abstract class Action extends BaseAction
      */
     public $controller;
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/cli/Command.php b/src/cli/Command.php
@@ -33,6 +33,7 @@ abstract class Command extends Controller
      */
     public $isolate = true;
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/cli/Queue.php b/src/cli/Queue.php
@@ -35,6 +35,7 @@ abstract class Queue extends BaseQueue implements BootstrapInterface
      */
     public $messageHandler;
 
+
     /**
      * @return string command id
      * @throws
diff --git a/src/cli/Signal.php b/src/cli/Signal.php
@@ -16,6 +16,7 @@ class Signal
 {
     private static $exit = false;
 
+
     /**
      * Checks exit signals
      * Used mainly by [[yii\queue\Queue]] to check, whether job execution
diff --git a/src/cli/VerboseBehavior.php b/src/cli/VerboseBehavior.php
@@ -31,6 +31,7 @@ class VerboseBehavior extends Behavior
 
     private $start;
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/closure/Behavior.php b/src/closure/Behavior.php
@@ -33,6 +33,7 @@ class Behavior extends \yii\base\Behavior
      */
     public $owner;
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/closure/Job.php b/src/closure/Job.php
@@ -22,6 +22,7 @@ class Job implements JobInterface
      */
     public $serialized;
 
+
     /**
      * Unserializes and executes a closure
      * @inheritdoc
diff --git a/src/debug/Panel.php b/src/debug/Panel.php
@@ -24,6 +24,7 @@ class Panel extends \yii\debug\Panel implements ViewContextInterface
 {
     private $_jobs = [];
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/drivers/amqp/Command.php b/src/drivers/amqp/Command.php
@@ -21,6 +21,7 @@ class Command extends CliCommand
      */
     public $queue;
 
+
     /**
      * Listens amqp-queue and runs new jobs.
      * It can be used as demon process.
diff --git a/src/drivers/amqp/Queue.php b/src/drivers/amqp/Queue.php
@@ -29,7 +29,6 @@ class Queue extends CliQueue
     public $queueName = 'queue';
     public $exchangeName = 'exchange';
     public $vhost = '/';
-
     /**
      * @var string command class name
      */
@@ -44,6 +43,7 @@ class Queue extends CliQueue
      */
     protected $channel;
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/drivers/beanstalk/Command.php b/src/drivers/beanstalk/Command.php
@@ -21,12 +21,12 @@ class Command extends CliCommand
      * @var Queue
      */
     public $queue;
-
     /**
      * @var string
      */
     public $defaultAction = 'info';
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/drivers/beanstalk/InfoAction.php b/src/drivers/beanstalk/InfoAction.php
@@ -22,6 +22,7 @@ class InfoAction extends Action
      */
     public $queue;
 
+
     /**
      * Info about queue status.
      */
diff --git a/src/drivers/beanstalk/Queue.php b/src/drivers/beanstalk/Queue.php
@@ -33,12 +33,12 @@ class Queue extends CliQueue
      * @var string beanstalk tube
      */
     public $tube = 'queue';
-
     /**
      * @var string command class name
      */
     public $commandClass = Command::class;
 
+
     /**
      * Runs all jobs from queue.
      */
diff --git a/src/drivers/db/Command.php b/src/drivers/db/Command.php
@@ -21,12 +21,12 @@ class Command extends CliCommand
      * @var Queue
      */
     public $queue;
-
     /**
      * @var string
      */
     public $defaultAction = 'info';
 
+
     /**
      * @inheritdoc
      */
@@ -50,7 +50,7 @@ public function actionRun()
      * Listens db-queue and runs new jobs.
      * It can be used as demon process.
      *
-     * @param integer $delay Number of seconds for waiting new job.
+     * @param int $delay Number of seconds for waiting new job.
      */
     public function actionListen($delay = 3)
     {
diff --git a/src/drivers/db/InfoAction.php b/src/drivers/db/InfoAction.php
@@ -24,6 +24,7 @@ class InfoAction extends Action
      */
     public $queue;
 
+
     /**
      * Info about queue status.
      */
diff --git a/src/drivers/db/Queue.php b/src/drivers/db/Queue.php
@@ -47,12 +47,12 @@ class Queue extends CliQueue
      * @var boolean ability to delete released messages from table
      */
     public $deleteReleased = true;
-
     /**
      * @var string command class name
      */
     public $commandClass = Command::class;
 
+
     /**
      * @inheritdoc
      */
@@ -83,7 +83,7 @@ public function run()
     /**
      * Listens db-queue and runs new jobs.
      *
-     * @param integer $delay number of seconds for waiting new job.
+     * @param int $delay number of seconds for waiting new job.
      */
     public function listen($delay)
     {
diff --git a/src/drivers/db/migrations/M161119140200Queue.php b/src/drivers/db/migrations/M161119140200Queue.php
@@ -19,6 +19,7 @@ class M161119140200Queue extends Migration
     public $tableName = '{{%queue}}';
     public $tableOptions;
 
+
     public function up()
     {
         $this->createTable($this->tableName, [
diff --git a/src/drivers/db/migrations/M170307170300Later.php b/src/drivers/db/migrations/M170307170300Later.php
@@ -18,6 +18,7 @@ class M170307170300Later extends Migration
 {
     public $tableName = '{{%queue}}';
 
+
     public function up()
     {
         $this->addColumn($this->tableName, 'timeout', $this->integer()->defaultValue(0)->notNull()->after('created_at'));
diff --git a/src/drivers/db/migrations/M170509001400Retry.php b/src/drivers/db/migrations/M170509001400Retry.php
@@ -18,6 +18,7 @@ class M170509001400Retry extends Migration
 {
     public $tableName = '{{%queue}}';
 
+
     public function up()
     {
         if ($this->db->driverName !== 'sqlite') {
diff --git a/src/drivers/db/migrations/M170601155600Priority.php b/src/drivers/db/migrations/M170601155600Priority.php
@@ -18,6 +18,7 @@ class M170601155600Priority extends Migration
 {
     public $tableName = '{{%queue}}';
 
+
     public function up()
     {
         $this->addColumn($this->tableName, 'priority', $this->integer()->unsigned()->notNull()->defaultValue(1024)->after('delay'));
diff --git a/src/drivers/file/Command.php b/src/drivers/file/Command.php
@@ -21,12 +21,12 @@ class Command extends CliCommand
      * @var Queue
      */
     public $queue;
-
     /**
      * @var string
      */
     public $defaultAction = 'info';
 
+
     /**
      * @inheritdoc
      */
@@ -50,7 +50,7 @@ public function actionRun()
      * Listens file-queue and runs new jobs.
      * It can be used as demon process.
      *
-     * @param integer $delay number of seconds for waiting new job.
+     * @param int $delay number of seconds for waiting new job.
      */
     public function actionListen($delay = 3)
     {
diff --git a/src/drivers/file/InfoAction.php b/src/drivers/file/InfoAction.php
@@ -22,6 +22,7 @@ class InfoAction extends Action
      */
     public $queue;
 
+
     /**
      * Info about queue status.
      */
@@ -43,7 +44,7 @@ public function run()
     }
 
     /**
-     * @return integer
+     * @return int
      */
     protected function getWaitingCount()
     {
@@ -54,7 +55,7 @@ protected function getWaitingCount()
     }
 
     /**
-     * @return integer
+     * @return int
      */
     protected function getDelayedCount()
     {
@@ -65,7 +66,7 @@ protected function getDelayedCount()
     }
 
     /**
-     * @return integer
+     * @return int
      */
     protected function getReservedCount()
     {
@@ -76,7 +77,7 @@ protected function getReservedCount()
     }
 
     /**
-     * @return integer
+     * @return int
      */
     protected function getDoneCount()
     {
diff --git a/src/drivers/file/Queue.php b/src/drivers/file/Queue.php
@@ -47,6 +47,7 @@ class Queue extends CliQueue
      */
     public $commandClass = Command::class;
 
+
     /**
      * @inheritdoc
      */
@@ -75,7 +76,7 @@ public function run()
     /**
      * Listens file-queue and runs new jobs.
      *
-     * @param integer $delay number of seconds for waiting new job.
+     * @param int $delay number of seconds for waiting new job.
      */
     public function listen($delay)
     {
diff --git a/src/drivers/gearman/Command.php b/src/drivers/gearman/Command.php
@@ -21,6 +21,7 @@ class Command extends CliCommand
      */
     public $queue;
 
+
     /**
      * Runs all jobs from gearman-queue.
      * It can be used as cron job.
diff --git a/src/drivers/gearman/Queue.php b/src/drivers/gearman/Queue.php
@@ -21,12 +21,12 @@ class Queue extends CliQueue
     public $host = 'localhost';
     public $port = 4730;
     public $channel = 'queue';
-
     /**
      * @var string command class name
      */
     public $commandClass = Command::class;
 
+
     /**
      * Runs all jobs from gearman-queue.
      */
diff --git a/src/drivers/redis/Command.php b/src/drivers/redis/Command.php
@@ -21,12 +21,12 @@ class Command extends CliCommand
      * @var Queue
      */
     public $queue;
-
     /**
      * @var string
      */
     public $defaultAction = 'info';
 
+
     /**
      * @inheritdoc
      */
diff --git a/src/drivers/redis/InfoAction.php b/src/drivers/redis/InfoAction.php
diff --git a/src/drivers/redis/Queue.php b/src/drivers/redis/Queue.php
diff --git a/src/drivers/sync/Queue.php b/src/drivers/sync/Queue.php
diff --git a/src/gii/Generator.php b/src/gii/Generator.php
diff --git a/src/serializers/JsonSerializer.php b/src/serializers/JsonSerializer.php

Original file line number	Diff line number	Diff line change
`@@ -16,6 +16,7 @@ class Signal`
`16`	`16`	`{`
`17`	`17`	`private static $exit = false;`
`18`	`18`
	`19`	`+`
`19`	`20`	`/**`
`20`	`21`	`* Checks exit signals`
`21`	`22`	`* Used mainly by [[yii\queue\Queue]] to check, whether job execution`