freyo / laravel-queue-cmq

src/Queue/CMQQueue.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,7 @@
     {
         $attributes = $this->getQueue($queue)->get_attributes();
 
-        return (int) $attributes->activeMsgNum;
+        return (int)$attributes->activeMsgNum;
     }
 
     /**

src/Queue/Driver/Queue.php

Spacing +3 added lines, -3 removed lines

@@ -186,7 +186,7 @@ 
         } else {
             $msgBody = $message->msgBody;
         }
-        $params        = array(
+        $params = array(
             'queueName'    => $this->queue_name,
             'msgBody'      => $msgBody,
             'delaySeconds' => $delayTime
@@ -212,7 +212,7 @@ 
             'queueName'    => $this->queue_name,
             'delaySeconds' => $delayTime
         );
-        $n      = 1;
+        $n = 1;
         foreach ($messages as $message) {
             $key = 'msgBody.' . $n;
             if ($this->encoding) {
@@ -324,7 +324,7 @@ 
         foreach ($receipt_handle_list as $receipt_handle) {
             $key          = 'receiptHandle.' . $n;
             $params[$key] = $receipt_handle;
-            $n            += 1;
+            $n += 1;
         }
         $this->cmq_client->batch_delete_message($params);
     }

src/Queue/Driver/Subscription.php

Spacing +4 added lines, -4 removed lines

@@ -46,7 +46,7 @@ 
             foreach ($subscription_meta->bindindKey as $tag) {
                 $key          = 'bindindKey.' . $n;
                 $params[$key] = $tag;
-                $n            += 1;
+                $n += 1;
             }
         }
 
@@ -55,7 +55,7 @@ 
             foreach ($subscription_meta->FilterTag as $tag) {
                 $key          = 'filterTag.' . $n;
                 $params[$key] = $tag;
-                $n            += 1;
+                $n += 1;
             }
         }
         $this->cmq_client->create_subscription($params);
@@ -171,7 +171,7 @@ 
             foreach ($subscription_meta->bindindKey as $tag) {
                 $key          = 'bindindKey.' . $n;
                 $params[$key] = $tag;
-                $n            += 1;
+                $n += 1;
             }
         }
 
@@ -180,7 +180,7 @@ 
             foreach ($subscription_meta->FilterTag as $tag) {
                 $key          = 'filterTag.' . $n;
                 $params[$key] = $tag;
-                $n            += 1;
+                $n += 1;
             }
         }
 

src/Queue/Driver/Topic.php

Spacing +2 added lines, -2 removed lines

@@ -147,7 +147,7 @@ 
             foreach ($vTagList as $tag) {
                 $key          = 'msgTag.' . $n;
                 $params[$key] = $tag;
-                $n            += 1;
+                $n += 1;
             }
         }
         $msgId = $this->cmq_client->publish_message($params);
@@ -199,7 +199,7 @@ 
             foreach ($vtagList as $tag) {
                 $key          = 'msgTag.' . $n;
                 $params[$key] = $tag;
-                $n            += 1;
+                $n += 1;
             }
         }
 

src/Queue/Connectors/CMQConnector.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
 
         $topic = new Account(array_get($config, 'options.topic.host'), $config['secret_id'], $config['secret_key']);
 
-        $this->dispatcher->listen(WorkerStopping::class, function () {
+        $this->dispatcher->listen(WorkerStopping::class, function() {
             //
         });
 

src/LaravelQueueCMQServiceProvider.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,7 @@
         /** @var QueueManager $queue */
         $queue = $this->app['queue'];
 
-        $queue->addConnector('cmq', function () {
+        $queue->addConnector('cmq', function() {
             return new CMQConnector($this->app['events']);
         });
     }