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/CMQHttp.php

Braces +3 added lines, -2 removed lines

@@ -41,8 +41,9 @@
         if (!$this->keep_alive) {
             $this->curl = curl_init();
         } else {
-            if ($this->curl == NULL)
-                $this->curl = curl_init();
+            if ($this->curl == NULL) {
+                            $this->curl = curl_init();
+            }
         }
 
         if ($this->curl == NULL) {

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/CMQClient.php

Braces +19 added lines, -14 removed lines

@@ -41,12 +41,13 @@ 
 
     public function set_sign_method($sign_method = 'sha1')
     {
-        if ($sign_method == 'sha1' || $sign_method == 'HmacSHA256')
-            $this->sign_method = 'HmacSHA1';
-        elseif ($sign_method == 'sha256')
-            $this->sign_method = 'HmacSHA256';
-        else
-            throw new CMQClientParameterException('Only support sign method HmasSHA256 or HmacSHA1 . Invalid sign method:' . $sign_method);
+        if ($sign_method == 'sha1' || $sign_method == 'HmacSHA256') {
+                    $this->sign_method = 'HmacSHA1';
+        } elseif ($sign_method == 'sha256') {
+                    $this->sign_method = 'HmacSHA256';
+        } else {
+                    throw new CMQClientParameterException('Only support sign method HmasSHA256 or HmacSHA1 . Invalid sign method:' . $sign_method);
+        }
 
     }
 
@@ -94,17 +95,21 @@ 
         $_params['Action']        = ucfirst($action);
         $_params['RequestClient'] = $this->version;
 
-        if (!isset($_params['SecretId']))
-            $_params['SecretId'] = $this->secretId;
+        if (!isset($_params['SecretId'])) {
+                    $_params['SecretId'] = $this->secretId;
+        }
 
-        if (!isset($_params['Nonce']))
-            $_params['Nonce'] = rand(1, 65535);
+        if (!isset($_params['Nonce'])) {
+                    $_params['Nonce'] = rand(1, 65535);
+        }
 
-        if (!isset($_params['Timestamp']))
-            $_params['Timestamp'] = time();
+        if (!isset($_params['Timestamp'])) {
+                    $_params['Timestamp'] = time();
+        }
 
-        if (!isset($_params['SignatureMethod']))
-            $_params['SignatureMethod'] = $this->sign_method;
+        if (!isset($_params['SignatureMethod'])) {
+                    $_params['SignatureMethod'] = $this->sign_method;
+        }
 
         $plainText            = Signature::makeSignPlainText($_params,
             $this->method, $this->host, $req_inter->uri);

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