release version 2.0.2

Author: samdark

CHANGELOG.md

@@ -1,16 +1,17 @@
 Yii2 Queue Extension Change Log
 ===============================
 
-2.0.2 under development
+2.0.2 December 26, 2018
 -----------------------
 
-- Enh #158: Add Amqp Interop driver (makasim)
-- Bug #180: Fixed info command of file driver (victorruan)
 - Bug #92: Resolve issue in debug panel (farmani-eigital)
-- Enh: Start and stop events of a worker (zhuravljov)
 - Bug #99: Retry connecting after connection has timed out for redis driver (cebe)
+- Bug #180: Fixed info command of file driver (victorruan)
+- Enh #158: Add Amqp Interop driver (makasim)
 - Enh #185: Loop object instead of Signal helper (zhuravljov)
 - Enh #188: Configurable verbose mode (zhuravljov)
+- Enh: Start and stop events of a worker (zhuravljov)
+
 
 2.0.1 November 13, 2017
 -----------------------

src/cli/Command.php

@@ -40,6 +40,7 @@ abstract class Command extends Controller
      */
     public $isolate = true;
 
+
     /**
      * @inheritdoc
      */

src/cli/Queue.php

@@ -31,6 +31,7 @@ abstract class Queue extends BaseQueue implements BootstrapInterface
      * @since 2.0.2
      */
     const EVENT_WORKER_STOP = 'workerStop';
+
     /**
      * @var array|string
      * @since 2.0.2
@@ -49,12 +50,14 @@ abstract class Queue extends BaseQueue implements BootstrapInterface
      * @internal for worker command only
      */
     public $messageHandler;
+
     /**
      * @var int current process ID of a worker.
      * @since 2.0.2
      */
     private $_workerPid;
 
+
     /**
      * @return string command id
      * @throws

src/cli/SignalLoop.php

@@ -36,10 +36,12 @@ class SignalLoop extends BaseObject implements LoopInterface
      * For example: SIGCONT
      */
     public $resumeSignals = [];
+
     /**
      * @var Queue
      */
     protected $queue;
+
     /**
      * @var bool status when exit signal was got.
      */
@@ -49,6 +51,7 @@ class SignalLoop extends BaseObject implements LoopInterface
      */
     private static $pause = false;
 
+
     /**
      * @param Queue $queue
      * @inheritdoc

src/cli/VerboseBehavior.php

@@ -28,6 +28,7 @@ class VerboseBehavior extends Behavior
      * @var Controller
      */
     public $command;
+
     /**
      * @var float timestamp
      */

src/drivers/amqp/Command.php

@@ -23,6 +23,7 @@ class Command extends CliCommand
      */
     public $queue;
 
+
     /**
      * @inheritdoc
      */

src/drivers/amqp/Queue.php

@@ -31,7 +31,6 @@ class Queue extends CliQueue
     public $queueName = 'queue';
     public $exchangeName = 'exchange';
     public $vhost = '/';
-
     /**
      * @var string command class name
      */
@@ -47,7 +46,6 @@ class Queue extends CliQueue
     protected $channel;
 
 
-
     /**
      * @inheritdoc
      */

src/drivers/amqp_interop/Command.php

@@ -22,6 +22,7 @@ class Command extends CliCommand
      */
     public $queue;
 
+
     /**
      * @inheritdoc
      */

src/drivers/amqp_interop/Queue.php

@@ -36,7 +36,6 @@ class Queue extends CliQueue
     const TTR = 'yii-ttr';
     const DELAY = 'yii-delay';
     const PRIORITY = 'yii-priority';
-
     const ENQUEUE_AMQP_LIB = 'enqueue/amqp-lib';
     const ENQUEUE_AMQP_EXT = 'enqueue/amqp-ext';
     const ENQUEUE_AMQP_BUNNY = 'enqueue/amqp-bunny';
@@ -48,169 +47,145 @@ class Queue extends CliQueue
      * @var string
      */
     public $dsn;
-
     /**
      * The message queue broker's host
      *
      * @var string|null
      */
     public $host;
-
     /**
      * The message queue broker's port
      *
      * @var string|null
      */
     public $port;
-
     /**
      * This is RabbitMQ user which is used to login on the broker
      *
      * @var string|null
      */
     public $user;
-
     /**
      * This is RabbitMQ password which is used to login on the broker
      *
      * @var string|null
      */
     public $password;
-
     /**
      * Virtual hosts provide logical grouping and separation of resources.
      *
      * @var string|null
      */
     public $vhost;
-
     /**
      * The time PHP socket waits for an information while reading. In seconds
      *
      * @var float|null
      */
     public $readTimeout;
-
     /**
      * The time PHP socket waits for an information while witting. In seconds
      *
      * @var float|null
      */
     public $writeTimeout;
-
     /**
      * The time RabbitMQ keeps the connection on idle. In seconds
      *
      * @var float|null
      */
     public $connectionTimeout;
-
     /**
      * The periods of time PHP pings the broker in order to prolong the connection timeout. In seconds
      *
      * @var float|null
      */
     public $heartbeat;
-
     /**
      * PHP uses one shared connection if set true
      *
      * @var bool|null
      */
     public $persisted;
-
     /**
      * The connection will be established as later as possible if set true
      *
      * @var bool|null
      */
     public $lazy;
-
     /**
      * If false prefetch_count option applied separately to each new consumer on the channel
      * If true prefetch_count option shared across all consumers on the channel
      *
      * @var bool|null
      */
     public $qosGlobal;
-
     /**
      * Defines number of message pre-fetched in advance on a channel basis.
      *
      * @var int|null
      */
     public $qosPrefetchSize;
-
     /**
      * Defines number of message pre-fetched in advance per consumer.
      *
      * @var int|null
      */
     public $qosPrefetchCount;
-
     /**
      * Defines whether secure connection should be used or not
      *
      * @var bool|null
      */
     public $sslOn;
-
     /**
      * Require verification of SSL certificate used.
      *
      * @var bool|null
      */
     public $sslVerify;
-
     /**
      * Location of Certificate Authority file on local filesystem which should be used with the verify_peer context option to authenticate the identity of the remote peer.
      *
      * @var string|null
      */
     public $sslCacert;
-
     /**
      * Path to local certificate file on filesystem.
      *
      * @var string|null
      */
     public $sslCert;
-
     /**
      * Path to local private key file on filesystem in case of separate files for certificate (local_cert) and private key.
      *
      * @var string|null
      */
     public $sslKey;
-
     /**
      * The queue used to consume messages from
      *
      * @var string
      */
     public $queueName = 'interop_queue';
-
     /**
      * The exchange used to publish messages to
      *
      * @var string
      */
     public $exchangeName = 'exchange';
-
     /**
      * Defines the amqp interop transport being internally used. Currently supports lib, ext and bunny values
      *
      * @var string
      */
     public $driver = self::ENQUEUE_AMQP_LIB;
-
     /**
      * This property should be an integer indicating the maximum priority the queue should support. Default is 10
      *
      * @var int
      */
     public $maxPriority = 10;
-
     /**
      * The property contains a command class which used in cli.
      *
@@ -224,14 +199,12 @@ class Queue extends CliQueue
      * @var AmqpContext
      */
     protected $context;
-
     /**
      * List of supported amqp interop drivers
      *
      * @var string[]
      */
     protected $supportedDrivers = [self::ENQUEUE_AMQP_LIB, self::ENQUEUE_AMQP_EXT, self::ENQUEUE_AMQP_BUNNY];
-
     /**
      * The property tells whether the setupBroker method was called or not.
      * Having it we can do broker setup only once per process.
@@ -240,6 +213,7 @@ class Queue extends CliQueue
      */
     protected $setupBrokerDone = false;
 
+
     /**
      * @inheritdoc
      */