freyo / laravel-queue-cmq

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

src/Queue/Driver/QueueMeta.php

Indentation +13 added lines, -13 removed lines

@@ -59,19 +59,19 @@
     public function __toString()
     {
         $info = ['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);
     }