freyo / laravel-queue-cmq

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

Indentation +2 added lines, -2 removed lines

@@ -245,8 +245,8 @@
         }
 
         return array("totalCoult"       => $resp['totalCount'],
-                     "subscriptionList" => $resp['subscriptionList'],
-                     "next_offset"      => $next_offset);
+                        "subscriptionList" => $resp['subscriptionList'],
+                        "next_offset"      => $next_offset);
     }
 }
 

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/Driver/Account.php

Indentation +3 added lines, -3 removed lines

@@ -130,7 +130,7 @@ 
         }
 
         return array("totalCount" => $ret_pkg['totalCount'],
-                     "queueList"  => $ret_pkg['queueList'], "next_offset" => $next_offset);
+                        "queueList"  => $ret_pkg['queueList'], "next_offset" => $next_offset);
     }
 
 
@@ -173,8 +173,8 @@ 
         }
 
         return array("totalCoult"  => $resp['totalCount'],
-                     "topicList"   => $resp['topicList'],
-                     "next_offset" => $next_offset);
+                        "topicList"   => $resp['topicList'],
+                        "next_offset" => $next_offset);
     }
 
 

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']);
         });
     }