freyo / laravel-queue-cmq

src/Queue/Driver/CMQExceptionBase.php

Indentation +2 added lines, -2 removed lines

@@ -37,8 +37,8 @@
     public function get_info()
     {
         $info = array("code"    => $this->code,
-                      "data"    => json_encode($this->data),
-                      "message" => $this->message);
+                        "data"    => json_encode($this->data),
+                        "message" => $this->message);
         return json_encode($info);
     }
 }

src/Queue/Driver/RequestInternal.php

Indentation +3 added lines, -3 removed lines

@@ -23,9 +23,9 @@
     public function __toString()
     {
         $info = array("method" => $this->method,
-                      "uri"    => $this->uri,
-                      "header" => json_encode($this->header),
-                      "data"   => $this->data);
+                        "uri"    => $this->uri,
+                        "header" => json_encode($this->header),
+                        "data"   => $this->data);
         return json_encode($info);
     }
 }

src/Queue/Driver/CMQServerNetworkException.php

Indentation +2 added lines, -2 removed lines

@@ -23,8 +23,8 @@
     public function __toString()
     {
         $info = array("status" => $this->status,
-                      "header" => json_encode($this->header),
-                      "data"   => $this->data);
+                        "header" => json_encode($this->header),
+                        "data"   => $this->data);
 
         return "CMQServerNetworkException  " . json_encode($info);
     }

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

Indentation +13 added lines, -13 removed lines

@@ -59,19 +59,19 @@
     public function __toString()
     {
         $info = array("visibilityTimeout"   => $this->visibilityTimeout,
-                      "maxMsgHeapNum"       => $this->maxMsgHeapNum,
-                      "maxMsgSize"          => $this->maxMsgSize,
-                      "msgRetentionSeconds" => $this->msgRetentionSeconds,
-                      "pollingWaitSeconds"  => $this->pollingWaitSeconds,
-                      "activeMsgNum"        => $this->activeMsgNum,
-                      "inactiveMsgNum"      => $this->inactiveMsgNum,
-                      "createTime"          => date("Y-m-d H:i:s", $this->createTime),
-                      "lastModifyTime"      => date("Y-m-d H:i:s", $this->lastModifyTime),
-                      "QueueName"           => $this->queueName,
-                      "rewindSeconds"       => $this->rewindSeconds,
-                      "rewindmsgNum"        => $this->rewindmsgNum,
-                      "minMsgTime"          => $this->minMsgTime,
-                      "delayMsgNum"         => $this->delayMsgNum);
+                        "maxMsgHeapNum"       => $this->maxMsgHeapNum,
+                        "maxMsgSize"          => $this->maxMsgSize,
+                        "msgRetentionSeconds" => $this->msgRetentionSeconds,
+                        "pollingWaitSeconds"  => $this->pollingWaitSeconds,
+                        "activeMsgNum"        => $this->activeMsgNum,
+                        "inactiveMsgNum"      => $this->inactiveMsgNum,
+                        "createTime"          => date("Y-m-d H:i:s", $this->createTime),
+                        "lastModifyTime"      => date("Y-m-d H:i:s", $this->lastModifyTime),
+                        "QueueName"           => $this->queueName,
+                        "rewindSeconds"       => $this->rewindSeconds,
+                        "rewindmsgNum"        => $this->rewindmsgNum,
+                        "minMsgTime"          => $this->minMsgTime,
+                        "delayMsgNum"         => $this->delayMsgNum);
         return json_encode($info);
     }
 }

src/Queue/Driver/Message.php

Indentation +6 added lines, -6 removed lines

@@ -39,12 +39,12 @@
     public function __toString()
     {
         $info = array("msgBody"          => $this->msgBody,
-                      "msgId"            => $this->msgId,
-                      "enqueueTime"      => date("Y-m-d H:i:s", $this->enqueueTime),
-                      "nextVisibleTime"  => date("Y-m-d H:i:s", $this->nextVisibleTime),
-                      "firstDequeueTime" => date("Y-m-d H:i:s", $this->firstDequeueTime),
-                      "dequeueCount"     => $this->dequeueCount,
-                      "receiptHandle"    => $this->receiptHandle);
+                        "msgId"            => $this->msgId,
+                        "enqueueTime"      => date("Y-m-d H:i:s", $this->enqueueTime),
+                        "nextVisibleTime"  => date("Y-m-d H:i:s", $this->nextVisibleTime),
+                        "firstDequeueTime" => date("Y-m-d H:i:s", $this->firstDequeueTime),
+                        "dequeueCount"     => $this->dequeueCount,
+                        "receiptHandle"    => $this->receiptHandle);
         return json_encode($info);
     }
 }

src/Queue/Driver/ResponseInternal.php

Indentation +2 added lines, -2 removed lines

@@ -22,8 +22,8 @@
     public function __toString()
     {
         $info = array("status" => $this->status,
-                      "header" => json_encode($this->header),
-                      "data"   => $this->data);
+                        "header" => json_encode($this->header),
+                        "data"   => $this->data);
         return json_encode($info);
     }
 }

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/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);
     }
 }