Apply fixes from StyleCI

Author: freyhsiao

src/Queue/CMQQueue.php

@@ -53,7 +53,7 @@ class CMQQueue extends Queue implements QueueContract
      *
      * @param \Freyo\LaravelQueueCMQ\Queue\Driver\Account $queueAccount
      * @param \Freyo\LaravelQueueCMQ\Queue\Driver\Account $topicAccount
-     * @param array $config
+     * @param array                                       $config
      *
      * @throws \ReflectionException
      */
@@ -75,7 +75,7 @@ public function __construct(Account $queueAccount, Account $topicAccount, array
      */
     public function isPlain()
     {
-        return (bool)Arr::get($this->plainOptions, 'enable');
+        return (bool) Arr::get($this->plainOptions, 'enable');
     }
 
     /**
@@ -97,18 +97,19 @@ public function size($queue = null)
     {
         $attributes = $this->getQueue($queue)->get_attributes();
 
-        return (int)$attributes->activeMsgNum;
+        return (int) $attributes->activeMsgNum;
     }
 
     /**
      * Push a new job onto the queue.
      *
      * @param string|object $job
-     * @param mixed $data
-     * @param string $queue
+     * @param mixed         $data
+     * @param string        $queue
      *
-     * @return mixed
      * @throws \Exception
+     *
+     * @return mixed
      */
     public function push($job, $data = '', $queue = null)
     {
@@ -128,12 +129,13 @@ public function push($job, $data = '', $queue = null)
      *
      * @param string $payload
      * @param string $queue
-     * @param array $options
+     * @param array  $options
      *
-     * @return \Freyo\LaravelQueueCMQ\Queue\Driver\Message|array
      * @throws \Freyo\LaravelQueueCMQ\Queue\Driver\CMQServerNetworkException
      * @throws \Freyo\LaravelQueueCMQ\Queue\Driver\CMQServerException
      * @throws \Exception
+     *
+     * @return \Freyo\LaravelQueueCMQ\Queue\Driver\Message|array
      */
     public function pushRaw($payload, $queue = null, array $options = [])
     {
@@ -155,7 +157,7 @@ function () use ($driver, $message, $queue) {
                         });
                 default:
                     throw new \InvalidArgumentException(
-                        'Invalid CMQ topic filter: ' . $this->topicOptions['filter']
+                        'Invalid CMQ topic filter: '.$this->topicOptions['filter']
                     );
             }
         }
@@ -169,12 +171,13 @@ function () use ($driver, $message, $queue) {
      * Push a new job onto the queue after a delay.
      *
      * @param \DateTimeInterface|\DateInterval|int $delay
-     * @param string|object $job
-     * @param mixed $data
-     * @param string $queue
+     * @param string|object                        $job
+     * @param mixed                                $data
+     * @param string                               $queue
      *
-     * @return mixed
      * @throws \Exception
+     *
+     * @return mixed
      */
     public function later($delay, $job, $data = '', $queue = null)
     {
@@ -206,9 +209,10 @@ public function pop($queue = null)
             $queue = $this->getQueue($queue);
             $message = $queue->receive_message($this->queueOptions['polling_wait_seconds']);
         } catch (CMQServerException $e) {
-            if (self::CMQ_QUEUE_NO_MESSAGE_CODE === (int)$e->getCode()) { // ignore no message
-                return null;
+            if (self::CMQ_QUEUE_NO_MESSAGE_CODE === (int) $e->getCode()) { // ignore no message
+                return;
             }
+
             throw $e;
         }
 

src/Queue/Connectors/CMQConnector.php

@@ -14,8 +14,9 @@ class CMQConnector implements ConnectorInterface
      *
      * @param array $config
      *
-     * @return \Illuminate\Contracts\Queue\Queue
      * @throws \ReflectionException
+     *
+     * @return \Illuminate\Contracts\Queue\Queue
      */
     public function connect(array $config)
     {

src/Queue/Jobs/CMQJob.php

@@ -24,11 +24,11 @@ class CMQJob extends Job implements JobContract
     /**
      * Create a new job instance.
      *
-     * @param \Illuminate\Container\Container $container
-     * @param \Freyo\LaravelQueueCMQ\Queue\CMQQueue $connection
+     * @param \Illuminate\Container\Container             $container
+     * @param \Freyo\LaravelQueueCMQ\Queue\CMQQueue       $connection
      * @param \Freyo\LaravelQueueCMQ\Queue\Driver\Message $message
-     * @param \Freyo\LaravelQueueCMQ\Queue\Driver\Queue $queue
-     * @param string $connectionName
+     * @param \Freyo\LaravelQueueCMQ\Queue\Driver\Queue   $queue
+     * @param string                                      $connectionName
      */
     public function __construct(Container $container, CMQQueue $connection, Message $message, Queue $queue, $connectionName)
     {