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

Indentation +3 added lines, -3 removed lines

@@ -23,9 +23,9 @@
     public function __toString()
     {
         $info = ['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/CMQClientException.php

Spacing +1 added lines, -1 removed lines

@@ -11,6 +11,6 @@
 
     public function __toString()
     {
-        return 'CMQClientException  '.$this->get_info();
+        return 'CMQClientException  ' . $this->get_info();
     }
 }

src/Queue/Driver/Topic.php

Indentation +2 added lines, -2 removed lines

@@ -238,7 +238,7 @@
         }
 
         return ['totalCoult'            => $resp['totalCount'],
-                     'subscriptionList' => $resp['subscriptionList'],
-                     'next_offset'      => $next_offset, ];
+                        'subscriptionList' => $resp['subscriptionList'],
+                        'next_offset'      => $next_offset, ];
     }
 }

Spacing +4 added lines, -4 removed lines

@@ -138,7 +138,7 @@ 
         if ($vTagList != null && is_array($vTagList) && !empty($vTagList)) {
             $n = 1;
             foreach ($vTagList as $tag) {
-                $key = 'msgTag.'.$n;
+                $key = 'msgTag.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -178,7 +178,7 @@ 
         $n = 1;
         if (is_array($vmessageList) && !empty($vmessageList)) {
             foreach ($vmessageList as $msg) {
-                $key = 'msgBody.'.$n;
+                $key = 'msgBody.' . $n;
                 if ($this->encoding) {
                     $params[$key] = base64_encode($msg);
                 } else {
@@ -190,7 +190,7 @@ 
         if ($vtagList != null && is_array($vtagList) && !empty($vtagList)) {
             $n = 1;
             foreach ($vtagList as $tag) {
-                $key = 'msgTag.'.$n;
+                $key = 'msgTag.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -230,7 +230,7 @@ 
         if ($offset == '') {
             $next_offset = count($resp['subscriptionList']);
         } else {
-            $next_offset = (int) $offset + count($resp['subscriptionList']);
+            $next_offset = (int)$offset + count($resp['subscriptionList']);
         }
 
         if ($next_offset >= $resp['totalCount']) {

src/Queue/Driver/Signature.php

Spacing +4 added lines, -4 removed lines

@@ -32,7 +32,7 @@ 
                 $retStr = base64_encode(hash_hmac('sha256', $srcStr, $secretKey, true));
                 break;
             default:
-                throw new Exception($method.' is not a supported encrypt method');
+                throw new Exception($method . ' is not a supported encrypt method');
                 break;
         }
 
@@ -54,12 +54,12 @@ 
         $requestMethod = 'POST', $requestHost = '',
         $requestPath = '/v2/index.php')
     {
-        $url = $requestHost.$requestPath;
+        $url = $requestHost . $requestPath;
 
         // 取出所有的参数
         $paramStr = self::_buildParamStr($requestParams, $requestMethod);
 
-        $plainText = $requestMethod.$url.$paramStr;
+        $plainText = $requestMethod . $url . $paramStr;
 
         return $plainText;
     }
@@ -96,7 +96,7 @@ 
             } else {
                 $paramStr .= '&';
             }
-            $paramStr .= $key.'='.$value;
+            $paramStr .= $key . '=' . $value;
             $i++;
         }
 

src/Queue/Driver/CMQExceptionBase.php

Indentation +2 added lines, -2 removed lines

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

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
 
     public function __toString()
     {
-        return 'CMQExceptionBase  '.$this->get_info();
+        return 'CMQExceptionBase  ' . $this->get_info();
     }
 
     public function get_info()

src/Queue/Driver/CMQClientNetworkException.php

Spacing +1 added lines, -1 removed lines

@@ -15,6 +15,6 @@
 
     public function __toString()
     {
-        return 'CMQClientNetworkException  '.$this->get_info();
+        return 'CMQClientNetworkException  ' . $this->get_info();
     }
 }

src/Queue/Driver/CMQServerException.php

Spacing +1 added lines, -1 removed lines

@@ -33,6 +33,6 @@
 
     public function __toString()
     {
-        return 'CMQServerException  '.$this->get_info().', RequestID:'.$this->request_id;
+        return 'CMQServerException  ' . $this->get_info() . ', RequestID:' . $this->request_id;
     }
 }

src/Queue/Driver/CMQClientParameterException.php

Spacing +1 added lines, -1 removed lines

@@ -15,6 +15,6 @@
 
     public function __toString()
     {
-        return 'CMQClientParameterException  '.$this->get_info();
+        return 'CMQClientParameterException  ' . $this->get_info();
     }
 }