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/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

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

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

src/Queue/Driver/CMQServerNetworkException.php

Spacing +1 added lines, -1 removed lines

@@ -26,6 +26,6 @@
                       'header' => json_encode($this->header),
                       'data'   => $this->data, ];
 
-        return 'CMQServerNetworkException  '.json_encode($info);
+        return 'CMQServerNetworkException  ' . json_encode($info);
     }
 }